commits@flink.apache.org, 2017-10

You are viewing a plain text version of this content. The canonical link for it is here.

- [1/7] flink git commit: [FLINK-5619] Add numStateEntries() method for all keyed backends - posted by al...@apache.org on 2017/10/02 08:19:36 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-7700] Fix RocksDB ListState merging - posted by al...@apache.org on 2017/10/02 08:19:37 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-5619] Consolidate ReducingState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/10/02 08:19:38 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-7700] Fix RocksDB ReducingState merging - posted by al...@apache.org on 2017/10/02 08:19:39 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-5619] Consolidate ListState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/10/02 08:19:40 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-7700] Fix RocksDB AggregatingState merging - posted by al...@apache.org on 2017/10/02 08:19:41 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-5619] Consolidate AggregatingState Tests in StateBackendTestBase - posted by al...@apache.org on 2017/10/02 08:19:42 UTC, 0 replies.
- flink git commit: [FLINK-7721] [DataStream] Only emit new min watermark iff it was aggregated from watermark-aligned inputs - posted by al...@apache.org on 2017/10/02 09:23:41 UTC, 1 replies.
- flink git commit: [FLINK-7662] [build] Remove now obsolete packaged licenses for previously shaded ASM - posted by se...@apache.org on 2017/10/02 12:38:18 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7721] Verify StatusWatermarkValve only emits WM iff it has aligned inputs - posted by al...@apache.org on 2017/10/02 14:46:46 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7728] [DataStream] Flush max watermark across all inputs once all become idle - posted by al...@apache.org on 2017/10/02 14:46:47 UTC, 1 replies.
- [3/4] flink git commit: [FLINK-7728] [DataStream] Make StatusWatermarkValve unit tests more fine-grained - posted by al...@apache.org on 2017/10/02 14:46:48 UTC, 1 replies.
- [4/4] flink git commit: [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest - posted by al...@apache.org on 2017/10/02 14:46:49 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7728] [DataStream] Simplify BufferedValveOutputHandler used in StatusWatermarkValveTest - posted by al...@apache.org on 2017/10/02 14:54:53 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7721] Verify StatusWatermarkValve only emits WM iff it has aligned inputs - posted by al...@apache.org on 2017/10/02 14:54:56 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph based REST handlers - posted by tr...@apache.org on 2017/10/02 20:29:42 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7668] Add ExecutionGraphCache for ExecutionGraph based REST handlers - posted by tr...@apache.org on 2017/10/02 20:29:43 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-7695] [flip6] Add JobConfigHandler for new RestServerEndpoint - posted by tr...@apache.org on 2017/10/02 20:29:44 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7708] [flip6] Add CheckpointConfigHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/02 20:29:45 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7710] [flip6] Add CheckpointStatisticsHandler for the new REST endpoint - posted by tr...@apache.org on 2017/10/02 20:29:46 UTC, 0 replies.
- flink git commit: [hotfix] [dispatcher] Remove leftover javadoc from DispatcherGateway - posted by ch...@apache.org on 2017/10/02 20:59:01 UTC, 0 replies.
- buildbot failure in on flink-docs-release-1.3 - posted by bu...@apache.org on 2017/10/03 01:06:05 UTC, 1 replies.
- flink git commit: [FLINK-7412][network] optimise NettyMessage.TaskEventRequest#readFrom() to read from netty buffers directly - posted by tr...@apache.org on 2017/10/04 13:14:08 UTC, 0 replies.
- flink git commit: [FLINK-7752] [flip-6] RedirectHandler should execute on the IO thread - posted by tr...@apache.org on 2017/10/04 15:52:37 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] [hbase] Set root log level to OFF for flink-hbase tests. - posted by se...@apache.org on 2017/10/04 19:12:21 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Fix testing log level in flink-runtime - posted by se...@apache.org on 2017/10/04 19:12:22 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [core] Prevent potential null pointer in MemorySize.equals(...) - posted by se...@apache.org on 2017/10/04 19:12:23 UTC, 0 replies.
- flink git commit: [FLINK-7446] [table] Change DefinedRowtimeAttribute to work on existing field. - posted by fh...@apache.org on 2017/10/05 07:09:47 UTC, 0 replies.
- flink git commit: [FLINK-7754] [rpc] Complete termination future after actor has been stopped - posted by tr...@apache.org on 2017/10/05 12:53:10 UTC, 0 replies.
- [01/14] flink git commit: [FLINK-7057][tests][hotfix] fix test instability of JobManagerCleanupITCase#testBlobServerCleanupCancelledJob - posted by tr...@apache.org on 2017/10/05 14:06:54 UTC, 0 replies.
- [02/14] flink git commit: [FLINK-7483][blob] prevent cleanup of re-registered jobs - posted by tr...@apache.org on 2017/10/05 14:06:55 UTC, 0 replies.
- [03/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:06:56 UTC, 0 replies.
- [04/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:06:57 UTC, 0 replies.
- [05/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:06:58 UTC, 0 replies.
- [06/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:06:59 UTC, 0 replies.
- [07/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:07:00 UTC, 0 replies.
- [08/14] flink git commit: [FLINK-7068][blob] change BlobService sub-classes for permanent and transient BLOBs - posted by tr...@apache.org on 2017/10/05 14:07:01 UTC, 0 replies.
- [09/14] flink git commit: [FLINK-7261][blob] extend BlobStore#get/put with boolean return values - posted by tr...@apache.org on 2017/10/05 14:07:02 UTC, 0 replies.
- [10/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys - posted by tr...@apache.org on 2017/10/05 14:07:03 UTC, 0 replies.
- [11/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys - posted by tr...@apache.org on 2017/10/05 14:07:04 UTC, 0 replies.
- [12/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys - posted by tr...@apache.org on 2017/10/05 14:07:05 UTC, 0 replies.
- [13/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys - posted by tr...@apache.org on 2017/10/05 14:07:06 UTC, 0 replies.
- [14/14] flink git commit: [FLINK-7068][blob] Introduce permanent and transient BLOB keys - posted by tr...@apache.org on 2017/10/05 14:07:07 UTC, 0 replies.
- flink git commit: [hotfix] Fix checkstyle problem in StatusWatermarkValve - posted by al...@apache.org on 2017/10/06 08:17:06 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7643] [core] Drop eager checks for file system support. - posted by se...@apache.org on 2017/10/06 10:05:50 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7643] [core] Misc. cleanups in FileSystem - posted by se...@apache.org on 2017/10/06 10:05:51 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7643] [core] Rework FileSystem loading to use factories - posted by se...@apache.org on 2017/10/06 10:05:52 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7643] [core] Rework FileSystem loading to use factories - posted by se...@apache.org on 2017/10/06 10:05:53 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7766] [file system sink] Drop obsolete reflective hflush calls - posted by se...@apache.org on 2017/10/06 16:53:52 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7767] [file system sinks] Avoid loading Hadoop conf dynamically at runtime - posted by se...@apache.org on 2017/10/06 16:53:53 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction - posted by se...@apache.org on 2017/10/06 17:54:03 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction - posted by se...@apache.org on 2017/10/06 17:54:04 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7768] [core] Load File Systems via Java Service abstraction - posted by se...@apache.org on 2017/10/06 17:54:05 UTC, 0 replies.
- buildbot success in on flink-docs-release-1.3 - posted by bu...@apache.org on 2017/10/07 02:10:44 UTC, 1 replies.
- [01/10] flink git commit: [hotfix] [docs] Fix broken links - posted by se...@apache.org on 2017/10/08 19:38:11 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-7772][blob] fix test instability in BlobCacheDeleteTest - posted by se...@apache.org on 2017/10/08 19:38:12 UTC, 0 replies.
- [03/10] flink git commit: [hotfix] [build] Remove no longer needed explicit Hadoop exclusions - posted by se...@apache.org on 2017/10/08 19:38:13 UTC, 0 replies.
- [04/10] flink git commit: [hotfix] [build] Properly exclude flink-python artifact from fat dist jar - posted by se...@apache.org on 2017/10/08 19:38:14 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-7742] [java api] [runtime] Fix array index out of bounds exceptions - posted by se...@apache.org on 2017/10/08 19:38:15 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-7739] [kafka connector] Fix test instabilities - posted by se...@apache.org on 2017/10/08 19:38:16 UTC, 0 replies.
- [07/10] flink git commit: [hotfix] [build] Remove incorrect and ineffective example exclusions - posted by se...@apache.org on 2017/10/08 19:38:17 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-7312] [checkstyle] Enable checkstyle for 'flink/core/memory/*' - posted by se...@apache.org on 2017/10/08 19:38:18 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-7312] [checkstyle] Enable checkstyle for 'flink/core/memory/*' - posted by se...@apache.org on 2017/10/08 19:38:19 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-7310] [core] always use the HybridMemorySegment - posted by se...@apache.org on 2017/10/08 19:38:20 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] [docs] Fix broken links - posted by se...@apache.org on 2017/10/08 19:42:30 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7742] [java api] [runtime] Fix array index out of bounds exceptions - posted by se...@apache.org on 2017/10/08 19:42:31 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7739] [kafka connector] Fix test instabilities - posted by se...@apache.org on 2017/10/08 19:42:32 UTC, 0 replies.
- flink git commit: [FLINK-7575] [webui] Show "Fetching" instead of 0 when IO metrics are not yet retrieved - posted by ch...@apache.org on 2017/10/09 14:04:48 UTC, 0 replies.
- flink git commit: [FLINK-7761] [examples] Include shaded guava dependency in Twitter example jar - posted by ch...@apache.org on 2017/10/09 16:09:53 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-6988][kafka] Add Kafka 0.11 tests for scaling down and up again - posted by al...@apache.org on 2017/10/09 16:59:07 UTC, 0 replies.
- [2/9] flink git commit: [hotfix][streaming] Fix typo in parameter and unify naming in test harnesses - posted by al...@apache.org on 2017/10/09 16:59:08 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-6988] Make TwoPhaseCommitSinkFunction work with Context - posted by al...@apache.org on 2017/10/09 16:59:09 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-6988] Add Kafka 0.11 connector maven module - posted by al...@apache.org on 2017/10/09 16:59:10 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] Don't use deprecated writeWithTimestamps in Kafka 0.10 tests - posted by al...@apache.org on 2017/10/09 16:59:11 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-6988][kafka] Implement our own KafkaProducer class with transactions recovery - posted by al...@apache.org on 2017/10/09 16:59:12 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-6988][kafka] Add test for failure before before checkpoint and scaling down - posted by al...@apache.org on 2017/10/09 16:59:13 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-6988][kafka] Add flink-connector-kafka-0.11 with exactly-once semantic - posted by al...@apache.org on 2017/10/09 16:59:14 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-6988][kafka] Add flink-connector-kafka-0.11 with exactly-once semantic - posted by al...@apache.org on 2017/10/09 16:59:15 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] [REST] Add utility HandlerRequest constructor - posted by tr...@apache.org on 2017/10/09 17:11:52 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7072] [REST] Define protocol for job submit/cancel/stop - posted by tr...@apache.org on 2017/10/09 17:11:53 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7072] [REST] Define protocol for job submit/cancel/stop - posted by tr...@apache.org on 2017/10/09 17:11:54 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #615 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/10 04:01:39 UTC, 0 replies.
- flink git commit: [FLINK-7744][docs] Add missing top links to documentation - posted by ch...@apache.org on 2017/10/10 12:05:38 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Polish grammar and tone for consistency and clarity - posted by ch...@apache.org on 2017/10/10 12:09:08 UTC, 0 replies.
- flink git commit: [FLINK-7632] [docs] Overhaul Cassandra connector docs - posted by ch...@apache.org on 2017/10/10 12:40:59 UTC, 0 replies.
- flink git commit: [hotfix] Remove exception stack trace from Emitter shutdown message - posted by al...@apache.org on 2017/10/10 13:57:33 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7394][core] Manage exclusive buffers in RemoteInputChannel - posted by ch...@apache.org on 2017/10/10 14:53:49 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7378][core] Create a fix size (non rebalancing) buffer pool type for the floating buffers - posted by ch...@apache.org on 2017/10/10 14:53:50 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7699][core] Define the BufferListener interface to replace EventlListener in BufferProvider - posted by ch...@apache.org on 2017/10/10 14:53:51 UTC, 0 replies.
- flink git commit: [FLINK-7790] [REST] Unresolved query params not added to request URL - posted by ch...@apache.org on 2017/10/10 14:56:50 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/10 15:35:04 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/10 15:35:05 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7709] Add CheckpointStatisticDetailsHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/10 15:35:06 UTC, 0 replies.
- flink git commit: [FLINK-7704] [flip6] Add JobPlanHandler for new RestServerEndpoint - posted by tr...@apache.org on 2017/10/10 21:03:18 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7410] [table] Use UserDefinedFunction.toString() to display operator names of UDFs. - posted by fh...@apache.org on 2017/10/10 21:09:57 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7776] [table] Prevent emission of identical update records in group aggregation. - posted by fh...@apache.org on 2017/10/10 21:09:58 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-6233] [table] Add inner rowtime window join between two streams for SQL. - posted by fh...@apache.org on 2017/10/10 21:09:59 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7491] [table] Add MultiSet type and COLLECT aggregation function to SQL. - posted by fh...@apache.org on 2017/10/10 21:10:00 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-6233] [table] Add more tests for rowtime window join + minor refactoring. - posted by fh...@apache.org on 2017/10/10 21:10:01 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #616 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/11 04:02:00 UTC, 0 replies.
- flink git commit: [FLINK-7792] [tests][client] Only suppress stdout for CLI tests - posted by ch...@apache.org on 2017/10/11 09:55:37 UTC, 0 replies.
- [1/5] flink git commit: [refactor] [tests] Generalize test handler generation - posted by ch...@apache.org on 2017/10/11 11:53:54 UTC, 0 replies.
- [2/5] flink git commit: [refactor] [tests] Generalize gateway mocking in ClusterClientTest - posted by ch...@apache.org on 2017/10/11 11:53:55 UTC, 0 replies.
- [3/5] flink git commit: [refactor] [tests] Refactor CliFrontend mocking into utility class - posted by ch...@apache.org on 2017/10/11 11:53:56 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7780] [Client] Move savepoint logic into ClusterClient - posted by ch...@apache.org on 2017/10/11 11:53:57 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7780] [REST] Define savepoint trigger protocol - posted by ch...@apache.org on 2017/10/11 11:53:58 UTC, 0 replies.
- flink git commit: [hotfix] [rpc] Add more logging for endpoint shutdown - posted by tr...@apache.org on 2017/10/11 12:29:06 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7707] [flip6] Add TaskCheckpointStatisticDetailsHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/11 12:43:09 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7707] [flip6] Add TaskCheckpointStatisticDetailsHandler for new REST endpoint - posted by tr...@apache.org on 2017/10/11 12:43:10 UTC, 0 replies.
- [01/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:01 UTC, 0 replies.
- [02/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:02 UTC, 0 replies.
- [03/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:03 UTC, 0 replies.
- [04/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:04 UTC, 0 replies.
- [05/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:05 UTC, 0 replies.
- [06/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:06 UTC, 0 replies.
- [07/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:07 UTC, 0 replies.
- [08/14] flink git commit: [FLINK-7769][QS] Move queryable state outside the runtime. - posted by kk...@apache.org on 2017/10/11 15:46:08 UTC, 0 replies.
- [09/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:09 UTC, 0 replies.
- [10/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:10 UTC, 0 replies.
- [11/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:11 UTC, 0 replies.
- [12/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:12 UTC, 0 replies.
- [13/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:13 UTC, 0 replies.
- [14/14] flink git commit: [FLINK-7770][QS] Hide the queryable state behind a proxy. - posted by kk...@apache.org on 2017/10/11 15:46:14 UTC, 0 replies.
- flink git commit: [hotfix] Harden TaskExecutorTest#testSlotAcceptance - posted by tr...@apache.org on 2017/10/11 16:23:45 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-7807] [REST] Log exceptions in HandlerUtils methods - posted by ch...@apache.org on 2017/10/11 21:32:35 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-7661][network] Add credit field in PartitionRequest message - posted by ch...@apache.org on 2017/10/11 21:32:36 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-7808] [REST] JobDetails constructor checks size of tasksPerState argument - posted by ch...@apache.org on 2017/10/11 21:32:37 UTC, 0 replies.
- [4/6] flink git commit: [hotfix][doc] Remove outdated best-practice suggestion to use .withParameters() - posted by ch...@apache.org on 2017/10/11 21:32:38 UTC, 0 replies.
- [5/6] flink git commit: [hotfix] [Javadoc] Fix typo in Javadoc for class InputTypeConfigurable - posted by ch...@apache.org on 2017/10/11 21:32:39 UTC, 0 replies.
- [6/6] flink git commit: [hotfix] [Javadoc] Fix typo in Javadoc for class FileSystem - posted by ch...@apache.org on 2017/10/11 21:32:40 UTC, 0 replies.
- flink git commit: [hotfix] [kafka] Fix the config parameter names in KafkaTestBase. - posted by ch...@apache.org on 2017/10/11 21:58:41 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #617 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/12 04:03:05 UTC, 0 replies.
- flink git commit: [hotfix] Convert queryable state POMs to tabs - posted by al...@apache.org on 2017/10/12 08:30:35 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7660] Support sideOutput in ProcessAllWindowFunction - posted by al...@apache.org on 2017/10/12 09:13:52 UTC, 0 replies.
- [2/2] flink git commit: [doc] Add ProcessWindowFunction to side output doc - posted by al...@apache.org on 2017/10/12 09:13:53 UTC, 0 replies.
- flink git commit: [FLINK-7818] Synchronize MetricStore access in TaskManagersHandler - posted by tr...@apache.org on 2017/10/12 14:35:08 UTC, 0 replies.
- flink git commit: [FLINK-7653] Properly implement Dispatcher#requestClusterOverview - posted by tr...@apache.org on 2017/10/12 16:30:45 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #618 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/13 04:01:43 UTC, 0 replies.
- flink git commit: [FLINK-7763] [table] Fix testing RowSink for enabled object reuse. - posted by fh...@apache.org on 2017/10/13 11:48:03 UTC, 1 replies.
- flink git commit: [FLINK-7835][cep] Fix duplicate() in NFASerializer. - posted by kk...@apache.org on 2017/10/13 11:50:55 UTC, 0 replies.
- flink git commit: [FLINK-7414] Pin scala quickstart to 2.11 - posted by al...@apache.org on 2017/10/13 12:31:54 UTC, 0 replies.
- flink git commit: [FLINK-7484] Perform proper deep copy in CaseClassSerializer.duplicate() - posted by al...@apache.org on 2017/10/13 13:02:32 UTC, 1 replies.
- [1/2] flink git commit: [hotfix] [docs] Remove weasel words, fix passive voice, typos and formatting - posted by se...@apache.org on 2017/10/13 22:34:23 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6615] [core] (followup) Add one more test for FileUtils - posted by se...@apache.org on 2017/10/13 22:34:24 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #619 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/14 04:00:57 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-5706] [file systems] Add S3 file systems without Hadoop dependencies - posted by se...@apache.org on 2017/10/14 17:08:06 UTC, 0 replies.
- [2/8] flink git commit: [hotfix] [tests] Move Kryo Registrations test to flink-runtime - posted by se...@apache.org on 2017/10/14 17:08:07 UTC, 0 replies.
- [3/8] flink git commit: [hotfix] [scala api] Move tests to correct package - posted by se...@apache.org on 2017/10/14 17:08:08 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] [scala api] Move tests to correct package - posted by se...@apache.org on 2017/10/14 17:08:09 UTC, 0 replies.
- [5/8] flink git commit: [hotfix] [scala api] Move tests to correct package - posted by se...@apache.org on 2017/10/14 17:08:10 UTC, 0 replies.
- [6/8] flink git commit: [hotfix] [scala api] Move tests to correct package - posted by se...@apache.org on 2017/10/14 17:08:11 UTC, 0 replies.
- [7/8] flink git commit: [hotfix] [scala api] Move tests to correct package - posted by se...@apache.org on 2017/10/14 17:08:12 UTC, 0 replies.
- [8/8] flink git commit: [hotfix] [scala api] Fix compiler warnings in Scala API - posted by se...@apache.org on 2017/10/14 17:08:13 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-7810] [build] (follow-up) Exclude unneeded dependencies from bumped akka - posted by se...@apache.org on 2017/10/14 23:30:56 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-7810] [build] Switch from custom Flakka to Akka 2.4.x - posted by se...@apache.org on 2017/10/14 23:30:57 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-7809] Remove support for Scala 2.10 - posted by se...@apache.org on 2017/10/14 23:30:58 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] [docs] Minor improvements to the 'building form source' guide. - posted by se...@apache.org on 2017/10/14 23:30:59 UTC, 0 replies.
- [5/8] flink git commit: [hotfix] [build] Filter out unnecessary maven JAR entries from 'force-shading' - posted by se...@apache.org on 2017/10/14 23:31:00 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-7842] [build] Shade org.codehouse.jackson in Hadoop - posted by se...@apache.org on 2017/10/14 23:31:01 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-7419] [build] Shade jackson dependency in flink-avro - posted by se...@apache.org on 2017/10/14 23:31:02 UTC, 0 replies.
- [8/8] flink git commit: [hotfix] [build] Exclude jline from ZooKeeper dependencies - posted by se...@apache.org on 2017/10/14 23:31:03 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #620 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2017/10/15 04:15:26 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-6805] [cassandra] Shade indirect netty4 dependency - posted by ch...@apache.org on 2017/10/15 16:43:32 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-6703][docs] Document how to take a savepoint on YARN - posted by ch...@apache.org on 2017/10/15 16:43:33 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-7774][network] fix not clearing deserializers on closing an input - posted by ch...@apache.org on 2017/10/15 16:43:34 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7791] [Client] Move LIST logic into ClusterClient - posted by ch...@apache.org on 2017/10/15 16:43:35 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7791] [REST][client] Integrate LIST command into RestClusterClient - posted by ch...@apache.org on 2017/10/15 16:43:36 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [build] Small improvements to the flink-mesos build - posted by se...@apache.org on 2017/10/15 17:10:25 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] [build] Change akka-remote exclusion pattern to fix maven warnings - posted by se...@apache.org on 2017/10/15 17:10:26 UTC, 0 replies.
- [3/4] flink git commit: [build] Move licenses for shaded dependencies into the NOTICE file - posted by se...@apache.org on 2017/10/15 17:10:27 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] [build] Remove outdated and obsolete plugin config in flink-runtime - posted by se...@apache.org on 2017/10/15 17:10:28 UTC, 0 replies.
- flink git commit: [FLINK-7140][blob] add an additional random component into the BlobKey - posted by tr...@apache.org on 2017/10/16 07:28:40 UTC, 0 replies.
- flink git commit: [FLINK-7810] Add more excludes in end-to-end tests - posted by al...@apache.org on 2017/10/16 08:29:46 UTC, 0 replies.
- flink git commit: [FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning - posted by al...@apache.org on 2017/10/16 08:40:17 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Change order of reduce and fold in window documentation - posted by al...@apache.org on 2017/10/16 11:32:17 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Change WindowFunction to ProcessWindowFunction in window doc - posted by al...@apache.org on 2017/10/16 11:32:18 UTC, 0 replies.
- flink git commit: [FLINK-7371] [table] Add support for constant parameters in OVER aggregate - posted by tw...@apache.org on 2017/10/16 15:58:34 UTC, 0 replies.
- flink git commit: [FLINK-7798] [table] Add support for stream time-windowed inner join to Table API - posted by fh...@apache.org on 2017/10/16 16:33:49 UTC, 0 replies.
- flink git commit: [FLINK-7426] [table] Support null values in keys - posted by tw...@apache.org on 2017/10/17 08:37:05 UTC, 0 replies.
- flink git commit: [FLINK-7785] [tests] Harden DispatcherTest - posted by tr...@apache.org on 2017/10/17 12:36:11 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5920][QS] Allow specification of port range for queryable state server. - posted by kk...@apache.org on 2017/10/18 06:49:13 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7788][QS] Allow specification of port range for queryable state proxy. - posted by kk...@apache.org on 2017/10/18 06:49:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7826][QS] Add support for all types of state to the QS Client. - posted by kk...@apache.org on 2017/10/18 08:03:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7826][QS] Add support for all types of state to the QS Client. - posted by kk...@apache.org on 2017/10/18 08:03:42 UTC, 0 replies.
- flink git commit: [FLINK-7757] [checkpointing] Introduce resource guard for RocksDBKeyedStateBackend to reduce locking and avoid blocking behavior. - posted by sr...@apache.org on 2017/10/18 10:22:23 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-6314] [cassandra] Support user-defined Mapper options - posted by ch...@apache.org on 2017/10/18 10:51:18 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7703] Port JobExceptionsHandler to new REST endpoint - posted by ch...@apache.org on 2017/10/18 10:51:19 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] Fix typo in CassandraSink - posted by ch...@apache.org on 2017/10/18 10:51:20 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7813] [metrics] Replace MetricRegistryThreadFactory - posted by ch...@apache.org on 2017/10/18 10:51:21 UTC, 0 replies.
- flink git commit: [FLINK-7368][metrics] Backport synchronization fix for MetricStore - posted by ch...@apache.org on 2017/10/18 13:48:53 UTC, 0 replies.
- flink git commit: [FLINK-7853] [table] Reject table function outer joins with predicates in Table API. - posted by fh...@apache.org on 2017/10/18 15:11:08 UTC, 1 replies.
- [1/3] flink git commit: [hotfix] Add QueryableState module to Libraries travis build. - posted by kk...@apache.org on 2017/10/19 10:07:36 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Rename QS ITCases to end in ITCase. - posted by kk...@apache.org on 2017/10/19 10:07:37 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] Rename QS ITCases to end in ITCase. - posted by kk...@apache.org on 2017/10/19 10:07:38 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7021] Add UnhandledErrorListener to ZooKeeperLeaderElectionService - posted by tr...@apache.org on 2017/10/19 12:59:12 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7021] Unregister ZooKeeperLeaderRetrievalService from CuratorFramework at shut down - posted by tr...@apache.org on 2017/10/19 12:59:13 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7021] [core] Handle Zookeeper leader retrieval error in TaskManager and throw RuntimeException - posted by tr...@apache.org on 2017/10/19 12:59:14 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7802] [table] Fix projection of all fields in CsvTableSource. - posted by fh...@apache.org on 2017/10/19 14:35:21 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7759] [table] Add support for field names with Boolean prefix. - posted by fh...@apache.org on 2017/10/19 14:35:22 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7759] [table] Add support for field names with Boolean prefix. - posted by fh...@apache.org on 2017/10/19 15:23:30 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7802] [table] Fix projection of all fields in CsvTableSource. - posted by fh...@apache.org on 2017/10/19 15:23:31 UTC, 0 replies.
- flink git commit: [FLINK-7854] [table] Reject lateral table outer joins with predicates in SQL. - posted by fh...@apache.org on 2017/10/19 17:10:18 UTC, 1 replies.
- flink git commit: [FLINK-5372] [tests] Fix RocksDBAsyncSnapshotTest.testCancelFullyAsyncCheckpoints() - posted by sr...@apache.org on 2017/10/20 04:27:12 UTC, 0 replies.
- [1/3] flink git commit: [hotfix][javadocs] Fix typos in RuntimeContext - posted by ch...@apache.org on 2017/10/20 06:35:54 UTC, 0 replies.
- [2/3] flink git commit: [hotfix][docs][javadocs] Remove double "the" - posted by ch...@apache.org on 2017/10/20 06:35:55 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-6907][core] Extend TupleGenerator javadocs - posted by ch...@apache.org on 2017/10/20 06:35:56 UTC, 0 replies.
- flink git commit: [FLINK-7831] Make last received heartbeat retrievable - posted by tr...@apache.org on 2017/10/20 12:16:37 UTC, 0 replies.
- flink git commit: [FLINK-7861] [flip6] Suppress ActorKilledException logging - posted by tr...@apache.org on 2017/10/20 12:38:04 UTC, 0 replies.
- flink git commit: [FLINK-7874] Add logging to the ClusterEntrypoints - posted by tr...@apache.org on 2017/10/20 12:40:02 UTC, 0 replies.
- flink git commit: [FLINK-7875] [flip6] Start StaticFileServerHandler with random tmp dir - posted by tr...@apache.org on 2017/10/20 12:41:53 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7855] [flip6] Add JobVertexMessageParameters - posted by tr...@apache.org on 2017/10/20 13:10:10 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7855] [flip6] Port JobVertexAccumulatorsHandler to REST endpoint - posted by tr...@apache.org on 2017/10/20 13:10:11 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-5968] Add documentation for WindowedStream.aggregate() - posted by al...@apache.org on 2017/10/21 07:35:14 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7837] Extend AggregateFunction.add() to work with immutable types - posted by al...@apache.org on 2017/10/21 07:35:15 UTC, 0 replies.
- flink git commit: [FLINK-7839] [doc] Add a note on possible maven failure for creating quickstart project. - posted by al...@apache.org on 2017/10/21 07:39:45 UTC, 0 replies.
- flink git commit: [FLINK-7832] [flip6] Extend SlotManager to report free slots per TM - posted by tr...@apache.org on 2017/10/21 09:04:09 UTC, 0 replies.
- flink git commit: [FLINK-7196][blob] add a TTL to all transient BLOBs - posted by tr...@apache.org on 2017/10/21 09:40:30 UTC, 0 replies.
- flink git commit: [FLINK-7262][blob] remove the unused FallbackLibraryCacheManager - posted by tr...@apache.org on 2017/10/21 09:44:24 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Harden SlotManagerTest#testTaskManagerTimeoutDoesNotRemoveSlots - posted by tr...@apache.org on 2017/10/21 14:52:47 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Remove redundant job status logging - posted by tr...@apache.org on 2017/10/21 14:52:48 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7793] [flip6] Defer slot release to ResourceManager - posted by tr...@apache.org on 2017/10/21 14:52:49 UTC, 0 replies.
- flink git commit: [hotfix] Ignore unstable Queryable State RocksDB integration tests - posted by al...@apache.org on 2017/10/22 11:06:05 UTC, 0 replies.
- flink git commit: [FLINK-7579] [Documentation] More accurate description of yarn.application-attempts. - posted by tr...@apache.org on 2017/10/22 11:43:54 UTC, 0 replies.
- flink git commit: [FLINK-7898] [flip6] Don't propagate CancellationExceptions in RegisteredRpcConnection - posted by tr...@apache.org on 2017/10/23 06:21:23 UTC, 0 replies.
- flink git commit: [FLINK-7899] Harden SlotManagerTest#testTaskManagerTimeoutDoesNotRemoveSlots by increasing timeout - posted by tr...@apache.org on 2017/10/23 07:32:33 UTC, 0 replies.
- flink git commit: [FLINK-7879][travis] Only execute RAT plugin in "Misc" profile - posted by ch...@apache.org on 2017/10/23 09:47:04 UTC, 0 replies.
- [flink-shaded] branch master updated: (#25) Add profile to create shaded source-jars - posted by ch...@apache.org on 2017/10/23 09:50:44 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [tests] Reduce visibility of helper class methods - posted by uc...@apache.org on 2017/10/23 12:34:25 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-7067] [jobmanager] Resume periodic checkpoints after failed cancel-job-with-savepoint - posted by uc...@apache.org on 2017/10/23 12:34:26 UTC, 1 replies.
- flink git commit: [FLINK-6245] Fix late side output documentation in Window documents. - posted by al...@apache.org on 2017/10/23 15:09:54 UTC, 0 replies.
- flink git commit: [FLINK-7868][travis] Only run checkstyle during compilation - posted by ch...@apache.org on 2017/10/24 08:54:07 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7905] [build] Update encrypted Travis S3 access keys - posted by se...@apache.org on 2017/10/24 09:48:01 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [tests] Increase stability of SavepointITCase - posted by se...@apache.org on 2017/10/24 09:48:02 UTC, 0 replies.
- flink git commit: [hotfix] Fix code formatting in window doc - posted by al...@apache.org on 2017/10/24 09:55:49 UTC, 0 replies.
- flink git commit: [FLINK-6861][metrics] Use OperatorID in metric system - posted by ch...@apache.org on 2017/10/24 11:30:46 UTC, 0 replies.
- flink git commit: [FLINK-7864] Support side-outputs in CoProcessFunction - posted by al...@apache.org on 2017/10/24 12:10:31 UTC, 0 replies.
- flink git commit: [FLINK-7783] Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() - posted by al...@apache.org on 2017/10/24 12:19:31 UTC, 0 replies.
- flink git commit: [FLINK-7783] Don't remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() - posted by al...@apache.org on 2017/10/24 12:21:45 UTC, 0 replies.
- [1/5] flink git commit: [hotfix][streaming] Fix formatting in OperatorChain - posted by al...@apache.org on 2017/10/24 14:14:12 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][tests] Add easier way to chain operator in StreamTaskTestHarness - posted by al...@apache.org on 2017/10/24 14:14:13 UTC, 0 replies.
- [3/5] flink git commit: [hotfix][tests] Extract AcknowledgeStreamMockEnvironment - posted by al...@apache.org on 2017/10/24 14:14:14 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7623][tests] Add tests verifying isRestored flag - posted by al...@apache.org on 2017/10/24 14:14:15 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7737][filesystem] Add syncOnFlush flag to StreamWriterBase - posted by al...@apache.org on 2017/10/24 14:14:16 UTC, 0 replies.
- flink git commit: [FLINK-7738] Add note about non-firing triggers with empty windows - posted by al...@apache.org on 2017/10/24 14:24:59 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] [docs] Fix typos in documentation - posted by se...@apache.org on 2017/10/24 14:50:43 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] [docs] Fix typo in monitoring REST API documentation - posted by se...@apache.org on 2017/10/24 14:50:44 UTC, 1 replies.
- [3/3] flink git commit: [hotfix] [docs] CEP docs review to remove weasel words, fix passive voice, typos and formatting - posted by se...@apache.org on 2017/10/24 14:50:45 UTC, 0 replies.
- flink git commit: [FLINK-7388] Don't set processing time as timestamp in ProcessFunction.onTimer() - posted by al...@apache.org on 2017/10/24 15:00:12 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Suppress unchecked warnings in HeartbeatManagerTest - posted by tr...@apache.org on 2017/10/24 15:16:45 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] [tests] Remove AbstractTestBase from CsvOutputFormatITCase and TextOutputFormatITCase - posted by tr...@apache.org on 2017/10/24 15:16:46 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-6046] offload large data from the TaskDeploymentDescriptor to the BlobServer - posted by tr...@apache.org on 2017/10/24 16:09:34 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-6046] offload large data from the TaskDeploymentDescriptor to the BlobServer - posted by tr...@apache.org on 2017/10/24 16:09:35 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] make BlobServer#serverSSLContext final - posted by tr...@apache.org on 2017/10/24 16:09:36 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-6046] Combine ExecutionGraph parameters into JobInformation - posted by tr...@apache.org on 2017/10/24 16:09:37 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-6046] Either store serialized value or permanent blob key in ExecutionGraph and ExecutionJobVertex - posted by tr...@apache.org on 2017/10/24 16:09:38 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-6046] Introduce BlobWriter interface to abstract BlobServer from ExecutionGraph - posted by tr...@apache.org on 2017/10/24 16:09:39 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7849] [hcatalog] Remove unnecessary/ineffective gauva shading - posted by se...@apache.org on 2017/10/24 17:19:35 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [docs] Fix typos in documentation - posted by se...@apache.org on 2017/10/24 17:19:37 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7755] [table] Fix NULL handling in batch joins. - posted by fh...@apache.org on 2017/10/24 18:29:04 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] [docs] Synchronize the Table API and SQL documentation of time-windowed joins. - posted by fh...@apache.org on 2017/10/24 18:29:05 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7821] [table] Deprecate Table.limit() and replace it by Table.offset() and Table.fetch(). - posted by fh...@apache.org on 2017/10/24 18:29:06 UTC, 0 replies.
- flink git commit: [FLINK-7882][build] Fixup FLINK-7810 by excluding remaining unused jaxb dependencies - posted by al...@apache.org on 2017/10/25 09:50:48 UTC, 0 replies.
- flink git commit: [hotifx][docs][yarn] Add required option -yn to WordCount example command - posted by ch...@apache.org on 2017/10/25 10:48:51 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7637] [kinesis] Fix at-least-once guarantee in FlinkKinesisProducer - posted by tz...@apache.org on 2017/10/25 11:53:02 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] [kinesis] Fix inproper test name in FlinkKinesisProducerTest - posted by tz...@apache.org on 2017/10/25 11:53:03 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] [kinesis] Properly add serialVersionUIDs to FlinkKinesisProducer classes - posted by tz...@apache.org on 2017/10/25 11:53:04 UTC, 0 replies.
- flink git commit: [FLINK-7611][metrics] Measure number of dropped late elements - posted by ch...@apache.org on 2017/10/25 12:22:21 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7669] Always load Flink classes via parent ClassLoader - posted by al...@apache.org on 2017/10/25 13:57:45 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7669] Add ClassLoader resolution order to classloader doc - posted by al...@apache.org on 2017/10/25 13:57:46 UTC, 0 replies.
- flink git commit: [hotfix] Fix broken master by passing alwaysParentFirstPatterns in JobMasterTest - posted by tr...@apache.org on 2017/10/25 16:31:29 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-6584] [table] Add SQL group window functions to retrieve time attributes. - posted by fh...@apache.org on 2017/10/25 20:02:14 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-6584] [docs] Add ROWTIME and PROCTIME group window functions to documentation. - posted by fh...@apache.org on 2017/10/25 20:02:15 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-6697] [table] Add support for group window ROWTIME to batch SQL & Table API. - posted by fh...@apache.org on 2017/10/25 20:02:16 UTC, 0 replies.
- flink git commit: [FLINK-7542] [table] Fix AggregationsITCase to not fail in certain timezones. - posted by fh...@apache.org on 2017/10/25 20:26:55 UTC, 0 replies.
- flink git commit: [FLINK-7666] Close TimeService after closing operators. - posted by kk...@apache.org on 2017/10/26 07:37:23 UTC, 0 replies.
- flink git commit: [FLINK-4831][metrics] Implement slf4j metric reporter - posted by ch...@apache.org on 2017/10/26 07:38:31 UTC, 0 replies.
- flink git commit: [FLINK-7502][metrics] Improve PrometheusReporter - posted by ch...@apache.org on 2017/10/26 07:48:38 UTC, 0 replies.
- flink git commit: [FLINK-7540] Apply consistent hostname normalization - posted by tr...@apache.org on 2017/10/26 07:51:03 UTC, 0 replies.
- flink git commit: [FLINK-7920] Make MiniClusterConfiguration immutable - posted by tr...@apache.org on 2017/10/26 08:22:57 UTC, 0 replies.
- flink git commit: [FLINK-7300] Demote ERROR to WARN on Commit Failure in KafkaConsumer - posted by al...@apache.org on 2017/10/26 10:27:30 UTC, 0 replies.
- flink git commit: [FLINK-5967] Add support for AggregatingState in user functions - posted by al...@apache.org on 2017/10/26 13:03:13 UTC, 0 replies.
- flink git commit: [hotfix] Reorder ProcessOperator methods so they conform to the order in the interface - posted by al...@apache.org on 2017/10/26 13:07:19 UTC, 0 replies.
- flink git commit: [FLINK-7368][metrics] Make MetricStore ThreadSafe class - posted by ch...@apache.org on 2017/10/26 14:43:25 UTC, 0 replies.
- flink git commit: [FLINK-7846] [elasticsearch] Remove unnecessary guava shading - posted by ch...@apache.org on 2017/10/26 14:44:44 UTC, 0 replies.
- flink git commit: [FLINK-7840] [build] Shade netty in akka - posted by se...@apache.org on 2017/10/26 16:53:59 UTC, 0 replies.
- [01/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:50 UTC, 0 replies.
- [02/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:51 UTC, 0 replies.
- [03/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:52 UTC, 0 replies.
- [04/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:53 UTC, 0 replies.
- [05/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:54 UTC, 0 replies.
- [06/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:55 UTC, 0 replies.
- [07/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:56 UTC, 0 replies.
- [08/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:57 UTC, 0 replies.
- [09/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:58 UTC, 0 replies.
- [10/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:01:59 UTC, 0 replies.
- [11/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:02:00 UTC, 0 replies.
- [12/13] flink git commit: [FLINK-7908][QS] Restructure the queryable state module. - posted by kk...@apache.org on 2017/10/26 17:02:01 UTC, 0 replies.
- [13/13] flink git commit: [FLINK-7824][QS] Put the QS modules in the opt folder. - posted by kk...@apache.org on 2017/10/26 17:02:02 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6173] [table] Clean-up flink-table jar and dependencies - posted by fh...@apache.org on 2017/10/26 21:53:41 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7051] [table] Bump Calcite version to 1.14. - posted by fh...@apache.org on 2017/10/26 21:53:42 UTC, 0 replies.
- flink git commit: [FLINK-6173] [table] Clean-up flink-table jar and dependencies - posted by fh...@apache.org on 2017/10/27 11:16:27 UTC, 0 replies.
- flink git commit: [hotfix] [table] Include commons-lang3 in flink-table artifact JAR. - posted by fh...@apache.org on 2017/10/27 12:23:17 UTC, 0 replies.
- flink-web git commit: [hotfix] [community] Fix typo Rohramnn -> Rohrmann - posted by tr...@apache.org on 2017/10/27 14:15:45 UTC, 0 replies.
- [1/8] flink git commit: [hotfix] [runtime] Minor optimization in CheckpointMetrics - posted by se...@apache.org on 2017/10/27 16:26:18 UTC, 0 replies.
- [2/8] flink git commit: [hotfix] [streaming] Move SerializedCheckpointData to proper scope for MessageAcknowledgingSourceBase - posted by se...@apache.org on 2017/10/27 16:26:19 UTC, 0 replies.
- [3/8] flink git commit: [hotfix] [hdfs] Avoid reparsing URIs in Hadoop File Status conversion - posted by se...@apache.org on 2017/10/27 16:26:20 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] [checkpoints] Remove unused and obsolete start()/stop() methods on CheckpointRecoveryFactory - posted by se...@apache.org on 2017/10/27 16:26:21 UTC, 0 replies.
- [5/8] flink git commit: [hotfix] [checkpoints] Remove incorrect 'Serializable' from StateBackendFactory - posted by se...@apache.org on 2017/10/27 16:26:22 UTC, 0 replies.
- [6/8] flink git commit: [hotfix] [core] Fix FileUtils.deletePathIfEmpty - posted by se...@apache.org on 2017/10/27 16:26:23 UTC, 0 replies.
- [7/8] flink git commit: [hotfix] [checkpoints] fix warnings and make minor improvements to CheckpointCoordinatorTest and SharedStateRegistry - posted by se...@apache.org on 2017/10/27 16:26:24 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-7924] [checkpoints] Fix incorrect names of checkpoint options - posted by se...@apache.org on 2017/10/27 16:26:25 UTC, 0 replies.
- flink git commit: [FLINK-7844] [ckPt] Fail unacknowledged pending checkpoints for fine grained recovery - posted by tr...@apache.org on 2017/10/27 17:28:49 UTC, 0 replies.
- [1/2] flink-web git commit: [hotfix] [contributing-code] Add org.apache.flink.shaded.* to import order section - posted by tr...@apache.org on 2017/10/29 14:12:06 UTC, 0 replies.
- [2/2] flink-web git commit: [hotfix] [faq] Remove faulty line break in heading - posted by tr...@apache.org on 2017/10/29 14:12:07 UTC, 0 replies.
- flink git commit: [FLINK-7880][QS] Fix QS test instabilities. - posted by kk...@apache.org on 2017/10/29 15:29:40 UTC, 0 replies.
- flink git commit: [FLINK-7933][metrics] Improve PrometheusReporter tests - posted by ch...@apache.org on 2017/10/30 08:38:16 UTC, 0 replies.
- [flink-shaded] tag 2.0 created (now 4c324d3) - posted by ch...@apache.org on 2017/10/30 09:15:33 UTC, 0 replies.
- svn commit: r22728 - in /release/flink: flink-shaded-1.0/ flink-shaded-2.0/ flink-shaded-2.0/flink-shaded-2.0-src.tgz flink-shaded-2.0/flink-shaded-2.0-src.tgz.asc flink-shaded-2.0/flink-shaded-2.0-src.tgz.md5 flink-shaded-2.0/flink-shaded-2.0-src.tgz.sha - posted by ch...@apache.org on 2017/10/30 09:24:32 UTC, 0 replies.
- flink git commit: [hotfix] Exclude Netty RejectedExecutionException from end-to-end tests - posted by tr...@apache.org on 2017/10/30 10:34:32 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-7548] [table] Refactor TableSource interface. - posted by fh...@apache.org on 2017/10/30 13:20:47 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-7548] [table] Refactor TableSource interface. - posted by fh...@apache.org on 2017/10/30 13:20:48 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-7548] [table] Refactor TableSource interface. - posted by fh...@apache.org on 2017/10/30 13:20:49 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-7548] [table] Refactor TableSource interface. - posted by fh...@apache.org on 2017/10/30 13:20:50 UTC, 0 replies.
- [flink-shaded] branch master updated: Increment version to 3.0 - posted by ch...@apache.org on 2017/10/30 14:56:08 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7739][tests] Properly close flink mini cluster - posted by tr...@apache.org on 2017/10/30 23:05:26 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7739][kafka-tests] Shutdown NetworkFailureProxy - posted by tr...@apache.org on 2017/10/30 23:05:27 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-6495][config] Revert heartbeat pause back to 60s - posted by tr...@apache.org on 2017/10/30 23:05:28 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7739] [tests] Remove unnecessary FlinkMiniCluster#awaitTermination calls - posted by tr...@apache.org on 2017/10/30 23:05:29 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7739][kafka-tests] Throttle down data producing thread - posted by tr...@apache.org on 2017/10/30 23:05:30 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] Remove redundant FutureUtils#getFailedFuture - posted by tr...@apache.org on 2017/10/30 23:09:55 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7940] Add FutureUtils.orTimeout - posted by tr...@apache.org on 2017/10/30 23:09:56 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-7950][build] add flink-queryable-state-runtime as a dependency to flink-dist - posted by kk...@apache.org on 2017/10/31 10:35:12 UTC, 0 replies.
- [2/2] flink git commit: [hotfix][QS] Disable RocksDB ITCases. - posted by kk...@apache.org on 2017/10/31 10:35:13 UTC, 0 replies.
- [01/10] flink git commit: [FLINK-7912][metrics][docs] Document metrics REST API - posted by ch...@apache.org on 2017/10/31 12:36:57 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-7781][metrics][REST] Support on-demand aggregations - posted by ch...@apache.org on 2017/10/31 12:36:58 UTC, 0 replies.
- [03/10] flink git commit: [hotfix][javadocs] Fix metric handler example javadocs - posted by ch...@apache.org on 2017/10/31 12:36:59 UTC, 0 replies.
- [04/10] flink git commit: [hotfix][metrics] Make ScopeFormats class final - posted by ch...@apache.org on 2017/10/31 12:37:00 UTC, 0 replies.
- [05/10] flink git commit: [hotfix][metrics] Remove MetricRegistryConfiguration#createScopeConfig - posted by ch...@apache.org on 2017/10/31 12:37:01 UTC, 0 replies.
- [06/10] flink git commit: [hotfix][metrics] Limit visibility of ScopeFormats constructor - posted by ch...@apache.org on 2017/10/31 12:37:02 UTC, 0 replies.
- [07/10] flink git commit: [hotfix][metrics] Remove unused ScopeFormats constructor - posted by ch...@apache.org on 2017/10/31 12:37:03 UTC, 0 replies.
- [08/10] flink git commit: [hotfix][metrics] Remove unnecessary ScopeFormats constructor - posted by ch...@apache.org on 2017/10/31 12:37:04 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-7418][build] Integrate flink-shaded-jackson2 - posted by ch...@apache.org on 2017/10/31 12:37:05 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-7418][build] Integrate flink-shaded-jackson2 - posted by ch...@apache.org on 2017/10/31 12:37:06 UTC, 0 replies.
- flink git commit: [hotfix][S3] Shade jackson 2.6 - posted by ch...@apache.org on 2017/10/31 20:07:06 UTC, 0 replies.