You are viewing a plain text version of this content. The canonical link for it is here.
- [flink] Git Push Summary - posted by tz...@apache.org on 2018/03/01 04:19:53 UTC, 2 replies.
- flink git commit: [FLINK-4387][QS] don't wait and process requests at Netty servers after shutdown request - posted by kk...@apache.org on 2018/03/01 09:45:52 UTC, 1 replies.
- flink git commit: [hotfix] [formats] Make ObjectMapper final in JsonNodeDeserializationSchema - posted by tw...@apache.org on 2018/03/01 09:58:54 UTC, 1 replies.
- flink git commit: [hotfix][build] Add missing shade-plugin execution id's - posted by ch...@apache.org on 2018/03/01 10:53:35 UTC, 1 replies.
- flink git commit: [FLINK-8814] [file system sinks] Control over the extension of part files created by BucketingSink. - posted by al...@apache.org on 2018/03/01 14:47:42 UTC, 1 replies.
- flink git commit: [FLINK-8810] Move end-to-end test scripts to end-to-end module - posted by al...@apache.org on 2018/03/01 14:59:31 UTC, 1 replies.
- [1/5] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/03/01 16:26:50 UTC, 0 replies.
- [2/5] flink-web git commit: [hotfix] Fix time in Flink 1.4.1 release blog post. - posted by fh...@apache.org on 2018/03/01 16:26:51 UTC, 0 replies.
- [3/5] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/03/01 16:26:52 UTC, 1 replies.
- [4/5] flink-web git commit: Add Uber and Telefonica to 'Powered By Flink' page and add logos to homepage carousel - posted by fh...@apache.org on 2018/03/01 16:26:53 UTC, 0 replies.
- [5/5] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/03/01 16:26:54 UTC, 1 replies.
- [1/2] flink-web git commit: Add 'End-to-end Exactly-once' blog post + image files - posted by fh...@apache.org on 2018/03/01 17:45:31 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/03/01 17:45:32 UTC, 2 replies.
- [1/2] flink git commit: [FLINK-6352] [kafka] Further improvements for timestamped-based startup mode - posted by tz...@apache.org on 2018/03/02 06:45:28 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6352] [kafka] Support to set offset of Kafka with specific date - posted by tz...@apache.org on 2018/03/02 06:45:29 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-6352] [kafka] Support to set offset of Kafka with specific date - posted by tz...@apache.org on 2018/03/02 06:46:42 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-6352] [kafka] Further improvements for timestamped-based startup mode - posted by tz...@apache.org on 2018/03/02 06:46:43 UTC, 0 replies.
- [01/12] flink git commit: [FLINK-8811] [flip6] Add initial implementation of the MiniClusterClient - posted by tr...@apache.org on 2018/03/02 07:53:01 UTC, 0 replies.
- [02/12] flink git commit: [FLINK-8808] [flip6] Allow RestClusterClient to connect to local dispatcher - posted by tr...@apache.org on 2018/03/02 07:53:02 UTC, 0 replies.
- [03/12] flink git commit: [FLINK-8811] [flip6] Implement MiniClusterClient#cancel - posted by tr...@apache.org on 2018/03/02 07:53:03 UTC, 0 replies.
- [04/12] flink git commit: [FLINK-8811] [flip6] Implement MiniClusterClient#getJobStatus - posted by tr...@apache.org on 2018/03/02 07:53:04 UTC, 0 replies.
- [05/12] flink git commit: [hotfix] Let ClusterClient only shut down own HaServices - posted by tr...@apache.org on 2018/03/02 07:53:05 UTC, 0 replies.
- [06/12] flink git commit: [hotfix] Unregister job from JobManagerRunner before completing the result future - posted by tr...@apache.org on 2018/03/02 07:53:06 UTC, 0 replies.
- [07/12] flink git commit: [hotfix] Introduce null checks for SlotManager#suspend - posted by tr...@apache.org on 2018/03/02 07:53:07 UTC, 0 replies.
- [08/12] flink git commit: [hotfix] Correct shutdown order of RestClusterClient - posted by tr...@apache.org on 2018/03/02 07:53:08 UTC, 0 replies.
- [09/12] flink git commit: [hotfix] Close ResourceManager LeaderRetrievalService in TaskExecutor - posted by tr...@apache.org on 2018/03/02 07:53:09 UTC, 0 replies.
- [10/12] flink git commit: [hotfix] Let AbstractEventTimeWindowCheckpointingITCase shutdown ZooKeeper after MiniCluster - posted by tr...@apache.org on 2018/03/02 07:53:10 UTC, 0 replies.
- [11/12] flink git commit: [hotfix] Let JobLeaderService terminate leader retrieval services - posted by tr...@apache.org on 2018/03/02 07:53:11 UTC, 1 replies.
- [12/12] flink git commit: [hotfix] Improve logging in ZooKeeper services - posted by tr...@apache.org on 2018/03/02 07:53:12 UTC, 1 replies.
- [01/12] flink git commit: [FLINK-8808] [flip6] Allow RestClusterClient to connect to local dispatcher - posted by tr...@apache.org on 2018/03/02 07:54:33 UTC, 0 replies.
- [02/12] flink git commit: [FLINK-8811] [flip6] Implement MiniClusterClient#getJobStatus - posted by tr...@apache.org on 2018/03/02 07:54:34 UTC, 0 replies.
- [03/12] flink git commit: [FLINK-8811] [flip6] Add initial implementation of the MiniClusterClient - posted by tr...@apache.org on 2018/03/02 07:54:35 UTC, 0 replies.
- [04/12] flink git commit: [hotfix] Let ClusterClient only shut down own HaServices - posted by tr...@apache.org on 2018/03/02 07:54:36 UTC, 0 replies.
- [05/12] flink git commit: [hotfix] Introduce null checks for SlotManager#suspend - posted by tr...@apache.org on 2018/03/02 07:54:37 UTC, 0 replies.
- [06/12] flink git commit: [FLINK-8811] [flip6] Implement MiniClusterClient#cancel - posted by tr...@apache.org on 2018/03/02 07:54:38 UTC, 0 replies.
- [07/12] flink git commit: [hotfix] Unregister job from JobManagerRunner before completing the result future - posted by tr...@apache.org on 2018/03/02 07:54:39 UTC, 0 replies.
- [08/12] flink git commit: [hotfix] Close ResourceManager LeaderRetrievalService in TaskExecutor - posted by tr...@apache.org on 2018/03/02 07:54:40 UTC, 0 replies.
- [09/12] flink git commit: [hotfix] Let AbstractEventTimeWindowCheckpointingITCase shutdown ZooKeeper after MiniCluster - posted by tr...@apache.org on 2018/03/02 07:54:41 UTC, 0 replies.
- [10/12] flink git commit: [hotfix] Correct shutdown order of RestClusterClient - posted by tr...@apache.org on 2018/03/02 07:54:42 UTC, 0 replies.
- flink git commit: [FLINK-8821] [table] Fix non-terminating decimal error - posted by tw...@apache.org on 2018/03/02 08:33:00 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8842] Change the Rest default port to 8081 - posted by tr...@apache.org on 2018/03/02 22:43:46 UTC, 1 replies.
- [2/2] flink git commit: [hotfix] Enable standalone HA mode by choosing HA port range - posted by tr...@apache.org on 2018/03/02 22:43:47 UTC, 1 replies.
- [1/6] flink git commit: [hotfix] [flip6] Harden JobMaster#triggerSavepoint - posted by tr...@apache.org on 2018/03/03 07:27:53 UTC, 1 replies.
- [2/6] flink git commit: [FLINK-8840] [yarn] Pull YarnClient and YarnConfiguration instantiation out of AbstractYarnClusterClient - posted by tr...@apache.org on 2018/03/03 07:27:54 UTC, 1 replies.
- [3/6] flink git commit: [FLINK-8826] [flip6] Start Yarn TaskExecutor with proper slots and memory - posted by tr...@apache.org on 2018/03/03 07:27:55 UTC, 1 replies.
- [4/6] flink git commit: [hotfix] Set default number of TaskManagers in FlinkYarnSessionCli for Flip6 - posted by tr...@apache.org on 2018/03/03 07:27:56 UTC, 1 replies.
- [5/6] flink git commit: [hotfix] Print correct web monitor URL in FlinkYarnSessionCli - posted by tr...@apache.org on 2018/03/03 07:27:57 UTC, 1 replies.
- [6/6] flink git commit: [FLINK-8459][flip6] Implement RestClusterClient.cancelWithSavepoint - posted by tr...@apache.org on 2018/03/03 07:27:58 UTC, 1 replies.
- flink git commit: [FLINK-8758] Make non-blocking ClusterClient.submitJob() public - posted by ch...@apache.org on 2018/03/05 10:42:11 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8700] Add getters to JobDetailsInfo - posted by ch...@apache.org on 2018/03/05 11:13:03 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8700] Add ClusterClient.getJobStatus() - posted by ch...@apache.org on 2018/03/05 11:13:04 UTC, 0 replies.
- flink git commit: [FLINK-8818][yarn/s3][tests] harden YarnFileStageTest upload test for eventual consistent read-after-write - posted by sr...@apache.org on 2018/03/05 11:18:05 UTC, 1 replies.
- flink git commit: [FLINK-8769][flip6] do not print error causing exceptions without debugging - posted by sr...@apache.org on 2018/03/05 11:23:07 UTC, 1 replies.
- flink git commit: [FLINK-8458][config][docs] Add config of credit-based network buffers - posted by sr...@apache.org on 2018/03/05 11:30:07 UTC, 1 replies.
- flink git commit: [FLINK-8859][checkpointing] RocksDB backend should pass WriteOption to Rocks.put() when restoring - posted by sr...@apache.org on 2018/03/05 12:48:04 UTC, 1 replies.
- flink git commit: [FLINK-8517] Fix missing synchronization in TaskEventDispatcher - posted by sr...@apache.org on 2018/03/05 14:21:38 UTC, 1 replies.
- [1/2] flink git commit: Fix checkstyle in ZooKeeperCompletedCheckpointStoreTest - posted by al...@apache.org on 2018/03/05 15:13:37 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by al...@apache.org on 2018/03/05 15:13:38 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by al...@apache.org on 2018/03/05 15:14:53 UTC, 0 replies.
- [2/2] flink git commit: Fix checkstyle in ZooKeeperCompletedCheckpointStoreTest - posted by al...@apache.org on 2018/03/05 15:14:54 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour with ITCase - posted by al...@apache.org on 2018/03/05 15:45:37 UTC, 0 replies.
- [2/4] flink git commit: Add more through test verification - posted by al...@apache.org on 2018/03/05 15:45:38 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by al...@apache.org on 2018/03/05 15:45:39 UTC, 0 replies.
- [4/4] flink git commit: Fix checkstyle in ZooKeeperCompletedCheckpointStoreTest - posted by al...@apache.org on 2018/03/05 15:45:40 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-8849][docs] Fix links to chaining docs - posted by ch...@apache.org on 2018/03/05 16:54:40 UTC, 0 replies.
- [2/6] flink git commit: [hotfix][docs] Remove reference to CheckpointedRestoring - posted by ch...@apache.org on 2018/03/05 16:54:41 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] Fix javadoc link in ClusterClient#triggerSavepoint - posted by ch...@apache.org on 2018/03/05 16:54:42 UTC, 1 replies.
- [4/6] flink git commit: [hotfix][REST] Fix CONTENT_TYPE header - posted by ch...@apache.org on 2018/03/05 16:54:43 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-8857][hbase] Remove redundant execute() call in hbase example - posted by ch...@apache.org on 2018/03/05 16:54:44 UTC, 1 replies.
- [6/6] flink git commit: [hotfix][docs] Drop the incorrect parallel remark in windowAll - posted by ch...@apache.org on 2018/03/05 16:54:45 UTC, 0 replies.
- [1/6] flink git commit: [hotfix][docs] Remove reference to CheckpointedRestoring - posted by ch...@apache.org on 2018/03/05 16:56:17 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-8849][docs] Fix links to chaining docs - posted by ch...@apache.org on 2018/03/05 16:56:18 UTC, 0 replies.
- [4/6] flink git commit: [hotfix][docs] Drop the incorrect parallel remark in windowAll - posted by ch...@apache.org on 2018/03/05 16:56:20 UTC, 0 replies.
- [6/6] flink git commit: [hotfix][REST] Fix CONTENT_TYPE header - posted by ch...@apache.org on 2018/03/05 16:56:22 UTC, 0 replies.
- [1/4] flink git commit: [hotfix][docs] Drop the incorrect parallel remark in windowAll - posted by ch...@apache.org on 2018/03/05 16:58:55 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8849][docs] Fix links to chaining docs - posted by ch...@apache.org on 2018/03/05 16:58:56 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8857][hbase] Remove redundant execute() call in hbase example - posted by ch...@apache.org on 2018/03/05 16:58:57 UTC, 0 replies.
- [4/4] flink git commit: [hotfix][docs] Remove reference to CheckpointedRestoring - posted by ch...@apache.org on 2018/03/05 16:58:58 UTC, 0 replies.
- [1/2] flink git commit: Revert "[FLINK-8487] Verify ZooKeeper checkpoint store behaviour with ITCase" - posted by al...@apache.org on 2018/03/05 19:07:29 UTC, 0 replies.
- [2/2] flink git commit: Revert "Add more through test verification" - posted by al...@apache.org on 2018/03/05 19:07:30 UTC, 0 replies.
- flink git commit: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by al...@apache.org on 2018/03/06 13:32:59 UTC, 0 replies.
- flink git commit: [FLINK-8560] Add KeyedProcessFunction exposing key in onTimer(). - posted by kk...@apache.org on 2018/03/06 16:18:37 UTC, 1 replies.
- flink git commit: [FLINK-8667] Expose key in KeyedBroadcastProcessFunction#onTimer() - posted by kk...@apache.org on 2018/03/06 16:35:51 UTC, 1 replies.
- flink git commit: [FLINK-8890] Compare checkpoints with order in CompletedCheckpoint.checkpointsMatch() - posted by al...@apache.org on 2018/03/07 13:37:48 UTC, 3 replies.
- [1/7] flink git commit: [FLINK-8824] [kafka connector] Replace Class.getCanonicalName() with Class.getName() - posted by se...@apache.org on 2018/03/07 20:25:37 UTC, 1 replies.
- [2/7] flink git commit: [FLINK-8827] [scripts] When FLINK_CONF_DIR contains spaces, ZooKeeper related scripts fail - posted by se...@apache.org on 2018/03/07 20:25:38 UTC, 1 replies.
- [3/7] flink git commit: [hotfix] [javadoc] Minor javadoc fix in TimestampAssigner.java - posted by se...@apache.org on 2018/03/07 20:25:39 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-8878] [tests] Add BlockerSync utility - posted by se...@apache.org on 2018/03/07 20:25:40 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-8877] [core] Set Kryo trace if Flink log level is TRACE - posted by se...@apache.org on 2018/03/07 20:25:41 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-8878] [core] Add concurrency check Kryo Serializer on DEBUG level - posted by se...@apache.org on 2018/03/07 20:25:42 UTC, 1 replies.
- [7/7] flink git commit: [FLINK-8879] [avro] Add concurrency check Avro Serializer on DEBUG level. - posted by se...@apache.org on 2018/03/07 20:25:43 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8878] [tests] Add BlockerSync utility - posted by se...@apache.org on 2018/03/07 20:54:43 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-8879] [avro] Add concurrency check Avro Serializer on DEBUG level. - posted by se...@apache.org on 2018/03/07 20:54:44 UTC, 0 replies.
- [5/7] flink git commit: [hotfix] [javadoc] Minor javadoc fix in TimestampAssigner.java - posted by se...@apache.org on 2018/03/07 20:54:45 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-8877] [core] Set Kryo trace if Flink log level is TRACE - posted by se...@apache.org on 2018/03/07 20:54:47 UTC, 0 replies.
- svn commit: r25580 - /release/flink/flink-1.4.2/ - posted by tz...@apache.org on 2018/03/08 04:28:07 UTC, 0 replies.
- [1/2] flink-web git commit: Add Flink 1.4.2 release - posted by tz...@apache.org on 2018/03/08 04:42:47 UTC, 0 replies.
- flink git commit: [hotfix] [build] Change REST port to 8081 for end-to-end testing scripts - posted by se...@apache.org on 2018/03/08 10:23:54 UTC, 1 replies.
- flink git commit: [FLINK-8839] [sql-client] Fix table source factory discovery - posted by tw...@apache.org on 2018/03/08 11:01:34 UTC, 1 replies.
- flink git commit: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour with ITCase - posted by al...@apache.org on 2018/03/08 15:54:11 UTC, 3 replies.
- [1/5] flink git commit: [FLINK-8856] [TaskManager] Move all cancellation interrupt calls to TaskCanceller thread - posted by se...@apache.org on 2018/03/08 16:51:00 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] [taskmanager] Fix checkstyle in Task and TaskTest - posted by se...@apache.org on 2018/03/08 16:51:01 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8883] [core] Make ThreadDeath a fatal error in ExceptionUtils - posted by se...@apache.org on 2018/03/08 16:51:02 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8885] [TaskManager] DispatcherThreadFactory registers a fatal error exception handler - posted by se...@apache.org on 2018/03/08 16:51:03 UTC, 1 replies.
- [5/5] flink git commit: [hotfix] [runtime] Harden FatalExitExceptionHandler - posted by se...@apache.org on 2018/03/08 16:51:04 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] [runtime] Harden FatalExitExceptionHandler - posted by se...@apache.org on 2018/03/08 16:54:42 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-8883] [core] Make ThreadDeath a fatal error in ExceptionUtils - posted by se...@apache.org on 2018/03/08 16:54:43 UTC, 0 replies.
- [3/5] flink git commit: [hotfix] [taskmanager] Fix checkstyle in Task and TaskTest - posted by se...@apache.org on 2018/03/08 16:54:44 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8856] [TaskManager] Move all cancellation interrupt calls to TaskCanceller thread - posted by se...@apache.org on 2018/03/08 16:54:46 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-8887][tests] Add single retry in MiniClusterClient - posted by ch...@apache.org on 2018/03/09 08:40:21 UTC, 1 replies.
- [2/5] flink git commit: [FLINK-8889][tests] Do not override cluster config values - posted by ch...@apache.org on 2018/03/09 08:40:22 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8860][flip6] stop SlotManager spamming logs for every TM heartbeat at log level 'info' - posted by ch...@apache.org on 2018/03/09 08:40:23 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8729][streaming] Refactor JSONGenerator to use jackson - posted by ch...@apache.org on 2018/03/09 08:40:24 UTC, 0 replies.
- [5/5] flink git commit: [hotfix][tests] Do not use singleActorSystem in LocalFlinkMiniCluster - posted by ch...@apache.org on 2018/03/09 08:40:25 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][tests] Do not use singleActorSystem in LocalFlinkMiniCluster - posted by ch...@apache.org on 2018/03/09 08:41:33 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8889][tests] Do not override cluster config values - posted by ch...@apache.org on 2018/03/09 08:41:34 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8860][flip6] stop SlotManager spamming logs for every TM heartbeat at log level 'info' - posted by ch...@apache.org on 2018/03/09 08:41:35 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8729][streaming] Refactor JSONGenerator to use jackson - posted by ch...@apache.org on 2018/03/09 08:41:36 UTC, 0 replies.
- flink git commit: [FLINK-8856] [TaskManager] Move all cancellation interrupt calls to TaskCanceller thread - posted by se...@apache.org on 2018/03/09 10:48:23 UTC, 0 replies.
- flink git commit: [FLINK-8860] Change slot-report message to DEBUG - posted by al...@apache.org on 2018/03/09 11:04:10 UTC, 1 replies.
- flink git commit: [FLINK-8896] [kafka08] remove all cancel MARKERs before trying to find partition leaders - posted by se...@apache.org on 2018/03/09 12:27:46 UTC, 2 replies.
- flink git commit: [FLINK-8091] [scripts] Support running historyserver in foreground - posted by se...@apache.org on 2018/03/09 12:47:42 UTC, 1 replies.
- flink git commit: [FLINK-8854] [table] Fix schema mapping with time attributes - posted by tw...@apache.org on 2018/03/09 12:56:42 UTC, 1 replies.
- [1/6] flink git commit: [hotfix] [network] Rename RecordWriter#closeBufferConsumer() to closeBufferBuilder() - posted by se...@apache.org on 2018/03/09 18:58:15 UTC, 1 replies.
- [2/6] flink git commit: [hotfix] [network] Various minor improvements - posted by se...@apache.org on 2018/03/09 18:58:16 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] [network] [tests] Make AwaitableBufferAvailablityListener thread-safe - posted by se...@apache.org on 2018/03/09 18:58:17 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-8755] [network] Fix SpilledSubpartitionView relying on the backlog for determining whether more data is available - posted by se...@apache.org on 2018/03/09 18:58:18 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-8786] [network] Fix SpillableSubpartitionView#getNextBuffer returning wrong isMoreAvailable when processing last in-memory buffer - posted by se...@apache.org on 2018/03/09 18:58:19 UTC, 1 replies.
- [6/6] flink git commit: [FLINK-8755] [FLINK-8786] [network] Add and improve subpartition tests - posted by se...@apache.org on 2018/03/09 18:58:20 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-8755] [FLINK-8786] [network] Add and improve subpartition tests - posted by se...@apache.org on 2018/03/09 18:58:33 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-8755] [network] Fix SpilledSubpartitionView relying on the backlog for determining whether more data is available - posted by se...@apache.org on 2018/03/09 18:58:34 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] [network] Various minor improvements - posted by se...@apache.org on 2018/03/09 18:58:35 UTC, 0 replies.
- [6/6] flink git commit: [hotfix] [network] [tests] Make AwaitableBufferAvailablityListener thread-safe - posted by se...@apache.org on 2018/03/09 18:58:37 UTC, 0 replies.
- [1/3] flink git commit: [hotfix][build] Enable incremental compilation - posted by ch...@apache.org on 2018/03/10 12:09:55 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8847][build] Always generate .class files for package-info.java - posted by ch...@apache.org on 2018/03/10 12:09:56 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-8800][REST] Reduce logging of all requests to TRACE - posted by ch...@apache.org on 2018/03/10 12:09:57 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8800][REST] Reduce logging of all requests to TRACE - posted by ch...@apache.org on 2018/03/10 12:10:41 UTC, 0 replies.
- [3/3] flink git commit: [hotfix][build] Enable incremental compilation - posted by ch...@apache.org on 2018/03/10 12:10:43 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8847][build] Always generate .class files for package-info.java - posted by ch...@apache.org on 2018/03/10 12:12:21 UTC, 0 replies.
- [2/2] flink git commit: [hotfix][build] Enable incremental compilation - posted by ch...@apache.org on 2018/03/10 12:12:22 UTC, 0 replies.
- [1/4] flink git commit: Add our own Deadline implementation - posted by al...@apache.org on 2018/03/11 15:27:42 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8758] Add FutureUtils.retrySuccessfulWithDelay() - posted by al...@apache.org on 2018/03/11 15:27:43 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8778] Port queryable state ITCases to use MiniClusterResource - posted by al...@apache.org on 2018/03/11 15:27:44 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8797] Port AbstractOperatorRestoreTestBase to MiniClusterResource - posted by al...@apache.org on 2018/03/11 15:27:45 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-8700] Add getters to JobDetailsInfo - posted by al...@apache.org on 2018/03/11 15:34:18 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-8778] Port queryable state ITCases to use MiniClusterResource - posted by al...@apache.org on 2018/03/11 15:34:19 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-8758] Add FutureUtils.retrySuccessfulWithDelay() - posted by al...@apache.org on 2018/03/11 15:34:20 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-8700] Add ClusterClient.getJobStatus() - posted by al...@apache.org on 2018/03/11 15:34:21 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-8797] Port AbstractOperatorRestoreTestBase to MiniClusterResource - posted by al...@apache.org on 2018/03/11 15:34:22 UTC, 0 replies.
- [6/6] flink git commit: Add our own Deadline implementation - posted by al...@apache.org on 2018/03/11 15:34:23 UTC, 0 replies.
- flink git commit: [FLINK-8911] Add separate script for nightly end-to-end tests - posted by al...@apache.org on 2018/03/11 15:39:01 UTC, 1 replies.
- Build failed in Jenkins: flink-snapshot-deployment #767 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/03/12 03:55:23 UTC, 0 replies.
- flink git commit: [FLINK-8274] [table] Split generated methods for preventing compiler exceptions - posted by tw...@apache.org on 2018/03/12 09:08:50 UTC, 1 replies.
- flink git commit: [FLINK-8922] Revert "[FLINK-8859][checkpointing] RocksDB backend should pass WriteOption to Rocks.put() when restoring" - posted by sr...@apache.org on 2018/03/12 10:24:58 UTC, 1 replies.
- flink git commit: [hotfix] Update docs version to Flink 1.4.2 - posted by tz...@apache.org on 2018/03/12 11:26:15 UTC, 0 replies.
- flink-web git commit: [hotfix] Update versions in quickstart scripts to 1.4.2 - posted by tz...@apache.org on 2018/03/12 11:38:54 UTC, 0 replies.
- flink git commit: [hotfix][RAT] Add serializer snapshot to exclusions - posted by ch...@apache.org on 2018/03/12 11:46:12 UTC, 1 replies.
- flink git commit: [hotfix][tests] Strip CompletionExceptions in MiniClusterClient#guardWithSingleRetry - posted by ch...@apache.org on 2018/03/12 14:09:20 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-7783] Don't always remove checkpoints in ZooKeeperCompletedCheckpointStore#recover() - posted by tz...@apache.org on 2018/03/12 15:13:15 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-8807] Fix ZookeeperCompleted checkpoint store can get stuck in infinite loop - posted by tz...@apache.org on 2018/03/12 15:13:16 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8890] Compare checkpoints with order in CompletedCheckpoint.checkpointsMatch() - posted by tz...@apache.org on 2018/03/12 15:13:17 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8487] Verify ZooKeeper checkpoint store behaviour with ITCase - posted by tz...@apache.org on 2018/03/12 15:13:18 UTC, 0 replies.
- [5/5] flink git commit: Commit for release 1.3.3 - posted by tz...@apache.org on 2018/03/12 15:13:19 UTC, 0 replies.
- flink git commit: [hotfix] Don't mark Table API & SQL as 'beta' anymore - posted by tw...@apache.org on 2018/03/12 15:29:35 UTC, 1 replies.
- flink git commit: [FLINK-8687] [sql-client] Make MaterializedCollectStreamResult#retrievePage to have resultLock - posted by tw...@apache.org on 2018/03/12 15:43:32 UTC, 1 replies.
- flink git commit: [hotfix] [yarn] Improve logging of container resources - posted by tr...@apache.org on 2018/03/12 17:39:09 UTC, 1 replies.
- flink git commit: [FLINK-8927][checkpointing] Eagerly release the checkpoint object in RocksDB incremental snapshots - posted by sr...@apache.org on 2018/03/12 21:47:43 UTC, 1 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #768 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/03/13 05:42:42 UTC, 0 replies.
- flink git commit: [FLINK-8783] [tests] Harden SlotPoolRpcTest - posted by tr...@apache.org on 2018/03/13 07:15:30 UTC, 1 replies.
- flink git commit: [FLINK-8934] [flip6] Properly cancel slot requests of otherwisely fulfilled requests - posted by tr...@apache.org on 2018/03/13 17:18:13 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-7521] Add config option to set the content length limit of REST server and client - posted by tr...@apache.org on 2018/03/14 08:40:43 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7521][flip6] Remove RestServerEndpoint#MAX_REQUEST_SIZE_BYTES - posted by tr...@apache.org on 2018/03/14 08:40:44 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-7521][flip6] Return HTTP 413 if request limit is exceeded. - posted by tr...@apache.org on 2018/03/14 08:40:45 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-7521][flip6] Return HTTP 413 if request limit is exceeded. - posted by tr...@apache.org on 2018/03/14 08:45:06 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-7521] Add config option to set the content length limit of REST server and client - posted by tr...@apache.org on 2018/03/14 08:45:08 UTC, 0 replies.
- [1/3] flink git commit: [hotfix] Ensure pristine release in tools/releasing/create_source_release.sh - posted by tz...@apache.org on 2018/03/14 10:24:20 UTC, 0 replies.
- [2/3] flink git commit: [hotfix] Properly delete temp flink dir in create_source_release.sh - posted by tz...@apache.org on 2018/03/14 10:24:21 UTC, 0 replies.
- [3/3] flink git commit: Commit for release 1.3.3 - posted by tz...@apache.org on 2018/03/14 10:24:22 UTC, 0 replies.
- flink git commit: [FLINK-8850] [sql-client] Add support for event-time in SQL Client - posted by tw...@apache.org on 2018/03/14 14:56:15 UTC, 1 replies.
- flink git commit: [FLINK-8832] [sql-client] Create a SQL Client Kafka 0.11 fat-jar - posted by tw...@apache.org on 2018/03/14 17:15:42 UTC, 1 replies.
- [1/9] flink git commit: [hotfix][docs][py] Fix class name in example - posted by ch...@apache.org on 2018/03/15 06:59:22 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8916][REST] Write/read checkpointing mode enum in lower case - posted by ch...@apache.org on 2018/03/15 06:59:23 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-8703][tests] Port NotSoMiniClusterIterations to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:24 UTC, 0 replies.
- [4/9] flink git commit: [hotfix][cli][tests] let CliFrontendRunTest extend from TestLogger - posted by ch...@apache.org on 2018/03/15 06:59:25 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-8904][cli][tests] Restore previous sysout - posted by ch...@apache.org on 2018/03/15 06:59:26 UTC, 1 replies.
- [6/9] flink git commit: [hotfix][javadocs] Update javadoc of InternalTimerService.registerEventTimeTimer() - posted by ch...@apache.org on 2018/03/15 06:59:27 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-8703][tests] Port StreamingScalabilityAndLatency to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:28 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-8703][tests] Port KafkaShortRetentionTestBase to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:29 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-4569][tests] Respect exceptions thrown in thread in JobRetrievalITCase - posted by ch...@apache.org on 2018/03/15 06:59:30 UTC, 1 replies.
- [1/9] flink git commit: [FLINK-8703][tests] Port StreamingScalabilityAndLatency to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:43 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8703][tests] Port NotSoMiniClusterIterations to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:44 UTC, 0 replies.
- [3/9] flink git commit: [hotfix][cli][tests] let CliFrontendRunTest extend from TestLogger - posted by ch...@apache.org on 2018/03/15 06:59:45 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-8916][REST] Write/read checkpointing mode enum in lower case - posted by ch...@apache.org on 2018/03/15 06:59:46 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-8703][tests] Port KafkaShortRetentionTestBase to MiniClusterResource - posted by ch...@apache.org on 2018/03/15 06:59:48 UTC, 0 replies.
- [7/9] flink git commit: [hotfix][docs][py] Fix class name in example - posted by ch...@apache.org on 2018/03/15 06:59:49 UTC, 0 replies.
- [8/9] flink git commit: [hotfix][javadocs] Update javadoc of InternalTimerService.registerEventTimeTimer() - posted by ch...@apache.org on 2018/03/15 06:59:50 UTC, 0 replies.
- svn commit: r25747 - /release/flink/flink-1.3.3/ - posted by tz...@apache.org on 2018/03/15 20:01:09 UTC, 0 replies.
- [1/2] flink-web git commit: Add Apache Flink release 1.3.3 blog post - posted by tz...@apache.org on 2018/03/15 20:20:18 UTC, 0 replies.
- flink git commit: [FLINK-8888] [Kinesis Connectors] Update the AWS SDK for flink kinesis connector - posted by se...@apache.org on 2018/03/16 12:50:13 UTC, 1 replies.
- flink git commit: [FLINK-8945] [kinesis] Allow customization of KinesisProxy - posted by se...@apache.org on 2018/03/16 12:52:28 UTC, 1 replies.
- flink git commit: Revert "[FLINK-7851] [scheduling] Improve scheduling balance by round robin distribution" - posted by tr...@apache.org on 2018/03/16 13:41:38 UTC, 1 replies.
- [1/7] flink git commit: [FLINK-9016] [flip6] Properly unregister jobs from JobMetricGroup - posted by tr...@apache.org on 2018/03/18 17:54:34 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-8812] [flip6] Set managed memory for TaskExecutor to 80 MB in MiniCluster - posted by tr...@apache.org on 2018/03/18 17:54:35 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-7804][flip6] Run AMRMClientAsync callbacks in main thread - posted by tr...@apache.org on 2018/03/18 17:54:36 UTC, 0 replies.
- [4/7] flink git commit: [hotfix][flip6] Only create new terminationFuture if MiniCluster is running - posted by tr...@apache.org on 2018/03/18 17:54:37 UTC, 1 replies.
- [5/7] flink git commit: [FLINK-8843][REST] Decouple bind REST address from advertised address - posted by tr...@apache.org on 2018/03/18 17:54:38 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-8894][REST] Set object codec for JsonGenerator used by CurrentJobIdsHandler - posted by tr...@apache.org on 2018/03/18 17:54:39 UTC, 1 replies.
- [7/7] flink git commit: [FLINK-8915] CheckpointingStatisticsHandler fails to return PendingCheckpointStats - posted by tr...@apache.org on 2018/03/18 17:54:40 UTC, 1 replies.
- [1/7] flink git commit: [FLINK-8812] [flip6] Set managed memory for TaskExecutor to 80 MB in MiniCluster - posted by tr...@apache.org on 2018/03/18 17:58:35 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-9016] [flip6] Properly unregister jobs from JobMetricGroup - posted by tr...@apache.org on 2018/03/18 17:58:36 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8843][REST] Decouple bind REST address from advertised address - posted by tr...@apache.org on 2018/03/18 17:58:37 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-7804][flip6] Run AMRMClientAsync callbacks in main thread - posted by tr...@apache.org on 2018/03/18 17:58:39 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8905][rest][client] fix RestClusterClient#getMaxSlots() returning 0 - posted by tr...@apache.org on 2018/03/19 15:53:38 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8906][flip6][tests] also test Flip6DefaultCLI in org.apache.flink.client.cli tests - posted by tr...@apache.org on 2018/03/19 15:53:39 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8906][flip6][tests] also test Flip6DefaultCLI in org.apache.flink.client.cli tests - posted by tr...@apache.org on 2018/03/19 15:54:34 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8905][rest][client] fix RestClusterClient#getMaxSlots() returning 0 - posted by tr...@apache.org on 2018/03/19 15:54:35 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-8935][tests] Implement MiniClusterClient#stop - posted by ch...@apache.org on 2018/03/20 09:14:50 UTC, 1 replies.
- [2/6] flink git commit: [FLINK-8935][tests] Implement MiniClusterClient#getAccumulators - posted by ch...@apache.org on 2018/03/20 09:14:51 UTC, 1 replies.
- [3/6] flink git commit: [FLINK-8948][runtime] Fix IllegalStateException when closing StreamTask - posted by ch...@apache.org on 2018/03/20 09:14:52 UTC, 1 replies.
- [4/6] flink git commit: [hotfix][javadocs] Minor javadoc fixes - posted by ch...@apache.org on 2018/03/20 09:14:53 UTC, 1 replies.
- [5/6] flink git commit: [FLINK-8935][tests] Implement MiniClusterClient#triggerSavepoint - posted by ch...@apache.org on 2018/03/20 09:14:54 UTC, 1 replies.
- [6/6] flink git commit: [FLINK-8935][tests] Implement MiniClusterClient#listJobs - posted by ch...@apache.org on 2018/03/20 09:14:55 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8830][YARN] YarnResourceManager throws NullPointerException - posted by tr...@apache.org on 2018/03/20 09:18:14 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8830] [yarn] Log reading of Hadoop's token file - posted by tr...@apache.org on 2018/03/20 09:18:15 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8830] [yarn] Log reading of Hadoop's token file - posted by tr...@apache.org on 2018/03/20 09:19:29 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8830][YARN] YarnResourceManager throws NullPointerException - posted by tr...@apache.org on 2018/03/20 09:19:30 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8942][runtime] Pass heartbeat target ResourceID - posted by tr...@apache.org on 2018/03/20 16:37:46 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-9019] Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs - posted by tr...@apache.org on 2018/03/20 16:37:47 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8801][yarn/s3] fix Utils#setupLocalResource() relying on consistent read-after-write - posted by tr...@apache.org on 2018/03/20 16:37:48 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-9019] Unclosed closeableRegistry in StreamTaskStateInitializerImpl#rawOperatorStateInputs - posted by tr...@apache.org on 2018/03/20 16:38:59 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8942][runtime] Pass heartbeat target ResourceID - posted by tr...@apache.org on 2018/03/20 16:39:00 UTC, 0 replies.
- flink git commit: [FLINK-8801][yarn/s3] fix Utils#setupLocalResource() relying on consistent read-after-write - posted by tr...@apache.org on 2018/03/20 16:41:19 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8881][runtime] Send accumulator updates via heartbeats - posted by tr...@apache.org on 2018/03/20 18:03:05 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8703][tests] Port SavepointMigrationTestBase to MiniClusterResource - posted by tr...@apache.org on 2018/03/20 18:03:06 UTC, 1 replies.
- flink git commit: [hotfix] [core] Add @FunctionalInterface to KeySelector - posted by se...@apache.org on 2018/03/21 08:31:47 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-9028] [yarn] Improve failure message if cluster cannot be started - posted by tr...@apache.org on 2018/03/21 09:57:18 UTC, 1 replies.
- [2/3] flink git commit: [FLINK-9028] [yarn] Perform parameters checking before Yarn starting cluster - posted by tr...@apache.org on 2018/03/21 09:57:19 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-9022][state] Fix resource release in StreamTaskStateInitializerImpl.streamOperatorStateContext() - posted by tr...@apache.org on 2018/03/21 09:57:20 UTC, 1 replies.
- flink git commit: [hotfix] [core] Fix checkstyle in 'org.apache.flink.api.common.state' - posted by se...@apache.org on 2018/03/21 10:37:50 UTC, 0 replies.
- flink git commit: [FLINK-8756][Client] Support ClusterClient.getAccumulators() in RestClusterClient - posted by tr...@apache.org on 2018/03/21 14:11:02 UTC, 1 replies.
- [1/8] flink git commit: [FLINK-7343][kafka-tests] Fix test at-least-once test instability - posted by ch...@apache.org on 2018/03/21 22:38:15 UTC, 0 replies.
- [2/8] flink git commit: [hotfix][kafka-tests] Clean up and drop unused field in KafkaProducerTestBase - posted by ch...@apache.org on 2018/03/21 22:38:16 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-8073][kafka-tests] Disable timeout in tests - posted by ch...@apache.org on 2018/03/21 22:38:17 UTC, 0 replies.
- [4/8] flink git commit: Revert "[FLINK-8703][tests] Port AutoParallelismITCase to flip6" - posted by ch...@apache.org on 2018/03/21 22:38:18 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-8649] [scala api] Pass on TypeInfo in StreamExecutionEnvironment.createInput - posted by ch...@apache.org on 2018/03/21 22:38:19 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8984][network] Drop taskmanager.exactly-once.blocking.data.enabled config option - posted by ch...@apache.org on 2018/03/21 22:38:20 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-9020][E2ETests] Use separate modules per testcase - posted by ch...@apache.org on 2018/03/21 22:38:21 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-8925][tests] Enable flip6 on travis - posted by ch...@apache.org on 2018/03/21 22:38:22 UTC, 1 replies.
- [1/8] flink git commit: [FLINK-8984][network] Drop taskmanager.exactly-once.blocking.data.enabled config option - posted by ch...@apache.org on 2018/03/21 22:39:43 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-7343][kafka-tests] Fix test at-least-once test instability - posted by ch...@apache.org on 2018/03/21 22:39:44 UTC, 0 replies.
- [3/8] flink git commit: [hotfix][kafka-tests] Clean up and drop unused field in KafkaProducerTestBase - posted by ch...@apache.org on 2018/03/21 22:39:45 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-8073][kafka-tests] Disable timeout in tests - posted by ch...@apache.org on 2018/03/21 22:39:46 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-9020][E2ETests] Use separate modules per testcase - posted by ch...@apache.org on 2018/03/21 22:39:47 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8649] [scala api] Pass on TypeInfo in StreamExecutionEnvironment.createInput - posted by ch...@apache.org on 2018/03/21 22:39:48 UTC, 0 replies.
- [7/8] flink git commit: Revert "[FLINK-8703][tests] Port AutoParallelismITCase to flip6" - posted by ch...@apache.org on 2018/03/21 22:39:49 UTC, 0 replies.
- flink git commit: [FLINK-8903] [table] Fix VAR_SAMP, VAR_POP, STDEV_SAMP, STDEV_POP functions on GROUP BY windows. - posted by fh...@apache.org on 2018/03/22 14:23:54 UTC, 1 replies.
- [1/6] flink git commit: [hotfix] [core] Make State Descriptors consistently use Preconditions instead of Objects. - posted by se...@apache.org on 2018/03/22 15:22:07 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] [core] Add missing serialVersionUID to MapStateDescriptor - posted by se...@apache.org on 2018/03/22 15:22:08 UTC, 0 replies.
- [3/6] flink git commit: [hotfix] [core] Demockitofy state descriptor tests - posted by se...@apache.org on 2018/03/22 15:22:09 UTC, 0 replies.
- [4/6] flink git commit: [FLINK-9034] [core] StateDescriptor does not throw away TypeInformation upon serialization. - posted by se...@apache.org on 2018/03/22 15:22:10 UTC, 0 replies.
- [5/6] flink git commit: [hotfix] [core] Consolidate serializer duplication tests in StateDescriptorTest where possible - posted by se...@apache.org on 2018/03/22 15:22:11 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-9035] [core] Fix state descriptor equals() and hashCode() handling - posted by se...@apache.org on 2018/03/22 15:22:12 UTC, 0 replies.
- [1/7] flink git commit: [hotfix] [core] Fix checkstyle in 'org.apache.flink.api.common.state' - posted by se...@apache.org on 2018/03/22 15:22:48 UTC, 0 replies.
- [2/7] flink git commit: [hotfix] [core] Add missing serialVersionUID to MapStateDescriptor - posted by se...@apache.org on 2018/03/22 15:22:49 UTC, 0 replies.
- [3/7] flink git commit: [hotfix] [core] Demockitofy state descriptor tests - posted by se...@apache.org on 2018/03/22 15:22:50 UTC, 0 replies.
- [4/7] flink git commit: [hotfix] [core] Make State Descriptors consistently use Preconditions instead of Objects. - posted by se...@apache.org on 2018/03/22 15:22:51 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-9034] [core] StateDescriptor does not throw away TypeInformation upon serialization. - posted by se...@apache.org on 2018/03/22 15:22:52 UTC, 0 replies.
- [6/7] flink git commit: [hotfix] [core] Consolidate serializer duplication tests in StateDescriptorTest where possible - posted by se...@apache.org on 2018/03/22 15:22:53 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-9035] [core] Fix state descriptor equals() and hashCode() handling - posted by se...@apache.org on 2018/03/22 15:22:54 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8562] [tests] Introduce private global configuration to YarnTestBase - posted by tr...@apache.org on 2018/03/22 17:32:27 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8562] [tests] Fix YARNSessionFIFOSecuredITCase - posted by tr...@apache.org on 2018/03/22 17:32:28 UTC, 1 replies.
- [1/2] flink git commit: [hotfix] Add generics to FutureUtils.toJava calls in ClusterClient - posted by tr...@apache.org on 2018/03/23 08:06:40 UTC, 1 replies.
- [2/2] flink git commit: [hotfix] Remove unnecessary transient modifiers in CheckpointStatsTracker - posted by tr...@apache.org on 2018/03/23 08:06:41 UTC, 1 replies.
- flink git commit: [FLINK-8919] [table] Add KeyedProcessFunctionWithCleanupState. - posted by fh...@apache.org on 2018/03/23 08:39:25 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled - posted by tr...@apache.org on 2018/03/23 11:38:30 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-9047] Fix slot recycling in case of failed release - posted by tr...@apache.org on 2018/03/23 11:38:31 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] Improve Flip-6 component logging - posted by tr...@apache.org on 2018/03/23 11:38:32 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-9027] [web] Clean up web UI resources by installing shut down hook - posted by tr...@apache.org on 2018/03/23 11:38:33 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] Remove unused method from SlotPool - posted by tr...@apache.org on 2018/03/23 11:38:34 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] Make RestServerEndpoint#uploadDir protected - posted by tr...@apache.org on 2018/03/23 11:38:35 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Log final status and exit code under lock - posted by tr...@apache.org on 2018/03/23 11:38:36 UTC, 0 replies.
- [8/9] flink git commit: [hotfix] Add FutureUtils#composeAfterwards - posted by tr...@apache.org on 2018/03/23 11:38:37 UTC, 1 replies.
- [9/9] flink git commit: [FLINK-8900] [yarn] Properly unregister application from Yarn RM - posted by tr...@apache.org on 2018/03/23 11:38:38 UTC, 1 replies.
- [1/9] flink git commit: [hotfix] Improve Flip-6 component logging - posted by tr...@apache.org on 2018/03/23 11:40:14 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8931] TASK_KILLING is not covered by match in TaskMonitor#whenUnhandled - posted by tr...@apache.org on 2018/03/23 11:40:15 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] Remove unused method from SlotPool - posted by tr...@apache.org on 2018/03/23 11:40:16 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-9047] Fix slot recycling in case of failed release - posted by tr...@apache.org on 2018/03/23 11:40:17 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] Make RestServerEndpoint#uploadDir protected - posted by tr...@apache.org on 2018/03/23 11:40:18 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] Log final status and exit code under lock - posted by tr...@apache.org on 2018/03/23 11:40:19 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-9027] [web] Clean up web UI resources by installing shut down hook - posted by tr...@apache.org on 2018/03/23 11:40:20 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-8964][tests] Port JobSubmissionFailsITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:03 UTC, 0 replies.
- [2/7] flink git commit: [hotfix][utils] Add ExceptionUtils#findThrowable with predicate - posted by ch...@apache.org on 2018/03/23 18:12:04 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8959][tests] Port AccumulatorLiveITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:05 UTC, 1 replies.
- [4/7] flink git commit: [FLINK-8956][tests] Port RescalingITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:06 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-8957][tests] Port JMXJobManagerMetricTest to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:07 UTC, 1 replies.
- [6/7] flink git commit: [FLINK-8958][tests] Port TaskCancelAsyncProducerConsumerITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:08 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-8965][tests] Port TimestampITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:09 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-8956][tests] Port RescalingITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:48 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-8965][tests] Port TimestampITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:49 UTC, 0 replies.
- [4/7] flink git commit: [hotfix][utils] Add ExceptionUtils#findThrowable with predicate - posted by ch...@apache.org on 2018/03/23 18:12:51 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-8964][tests] Port JobSubmissionFailsITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:53 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-8958][tests] Port TaskCancelAsyncProducerConsumerITCase to flip6 - posted by ch...@apache.org on 2018/03/23 18:12:54 UTC, 0 replies.
- flink git commit: [hotfix] [table] Add Java deprecation annotation to TableEnvironment.sql(). - posted by fh...@apache.org on 2018/03/23 21:15:44 UTC, 1 replies.
- [1/3] flink git commit: [FLINK-8975] [test] Add Kafka events generator job for StateMachineExample - posted by tz...@apache.org on 2018/03/26 06:25:42 UTC, 1 replies.
- [2/3] flink git commit: [FLINK-8975] [test] Add resume from savepoint end-to-end test - posted by tz...@apache.org on 2018/03/26 06:25:43 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-8976] [test] Add end-to-end tests for resuming savepoint with differrent parallelism - posted by tz...@apache.org on 2018/03/26 06:25:44 UTC, 1 replies.
- [1/5] flink git commit: [hotfix][tests] Do not hide original exception in the tests - posted by tr...@apache.org on 2018/03/26 07:33:31 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][runtime] Remove unused method - posted by tr...@apache.org on 2018/03/26 07:33:32 UTC, 0 replies.
- [3/5] flink git commit: [hotfix][tests] Allow to run SpillableSubpartitionTests in the loop - posted by tr...@apache.org on 2018/03/26 07:33:33 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8721][flip6] Handle archiving failures for accumulators - posted by tr...@apache.org on 2018/03/26 07:33:34 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-8721][flip6] Handle archiving failures for accumulators - posted by tr...@apache.org on 2018/03/26 07:33:35 UTC, 0 replies.
- [1/5] flink git commit: [hotfix][runtime] Remove unused method - posted by tr...@apache.org on 2018/03/26 07:34:46 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][tests] Do not hide original exception in the tests - posted by tr...@apache.org on 2018/03/26 07:34:47 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8721][flip6] Handle archiving failures for accumulators - posted by tr...@apache.org on 2018/03/26 07:34:48 UTC, 0 replies.
- [5/5] flink git commit: [hotfix][tests] Allow to run SpillableSubpartitionTests in the loop - posted by tr...@apache.org on 2018/03/26 07:34:50 UTC, 0 replies.
- flink git commit: [FLINK-8852] [sql-client] Add support for FLIP-6 in SQL Client - posted by tw...@apache.org on 2018/03/26 13:56:46 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8972] [e2eTests] Add DataSetAllroundTestProgram and e2e test script. - posted by tw...@apache.org on 2018/03/26 16:00:03 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8972] [e2eTests] Remove IDE warnings and simplify pom.xml - posted by tw...@apache.org on 2018/03/26 16:00:04 UTC, 1 replies.
- flink git commit: [FLINK-8833] [sql-client] Create a SQL Client JSON format fat-jar - posted by tw...@apache.org on 2018/03/26 16:42:52 UTC, 1 replies.
- flink git commit: [hotfix] [sql-client] Add flink-sql-client as 'provided' to flink-dist - posted by tw...@apache.org on 2018/03/26 17:05:22 UTC, 1 replies.
- [1/9] flink git commit: [FLINK-8789] Throw IllegalStateException when calling Task#stopExecution on not running Task - posted by tr...@apache.org on 2018/03/27 09:37:29 UTC, 1 replies.
- [2/9] flink git commit: [FLINK-8901] [yarn] Set proper Yarn application name - posted by tr...@apache.org on 2018/03/27 09:37:30 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] Remove unused applicationName parameter from FlinkYarnSessionCli#createDescriptor - posted by tr...@apache.org on 2018/03/27 09:37:31 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-5411] [flip6] Fix JobLeaderIdService shut down in ResourceManager - posted by tr...@apache.org on 2018/03/27 09:37:32 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-8940] [flip6] Add support for dispose savepoint - posted by tr...@apache.org on 2018/03/27 09:37:33 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] Improve logging in AkkaRpcActors - posted by tr...@apache.org on 2018/03/27 09:37:34 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Poll invariant variables out of polling loop in RestClusterClient#rescaleJob - posted by tr...@apache.org on 2018/03/27 09:37:35 UTC, 1 replies.
- [8/9] flink git commit: [hotfix] Add Assert.fail to RestClusterClientTest - posted by tr...@apache.org on 2018/03/27 09:37:36 UTC, 1 replies.
- [9/9] flink git commit: [hotfix] Set RescalingHandlers timeout to RpcUtils.INF_TIMEOUT - posted by tr...@apache.org on 2018/03/27 09:37:37 UTC, 1 replies.
- [2/9] flink git commit: [hotfix] Remove unused applicationName parameter from FlinkYarnSessionCli#createDescriptor - posted by tr...@apache.org on 2018/03/27 09:38:45 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-5411] [flip6] Fix JobLeaderIdService shut down in ResourceManager - posted by tr...@apache.org on 2018/03/27 09:38:46 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-8901] [yarn] Set proper Yarn application name - posted by tr...@apache.org on 2018/03/27 09:38:47 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] Improve logging in AkkaRpcActors - posted by tr...@apache.org on 2018/03/27 09:38:48 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-8940] [flip6] Add support for dispose savepoint - posted by tr...@apache.org on 2018/03/27 09:38:49 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9067] [e2eTests] Fix test and simplify code - posted by tw...@apache.org on 2018/03/27 13:56:18 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-9067] [e2eTests] Add StreamSQLTestProgram and test run script. - posted by tw...@apache.org on 2018/03/27 13:56:19 UTC, 1 replies.
- flink git commit: [hotfix] Fix wrong parent version - posted by tw...@apache.org on 2018/03/27 14:35:30 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider - posted by tw...@apache.org on 2018/03/27 14:37:51 UTC, 3 replies.
- [2/2] flink git commit: [FLINK-9093] [docs] Ship jQuery library without external provider - posted by tw...@apache.org on 2018/03/27 14:37:52 UTC, 3 replies.
- [1/5] flink-web git commit: [FLINK-9062] Ship jQuery without external provider - posted by tw...@apache.org on 2018/03/27 15:13:07 UTC, 0 replies.
- [2/5] flink-web git commit: [FLINK-9062] Ship jQuery without external provider - posted by tw...@apache.org on 2018/03/27 15:13:08 UTC, 0 replies.
- [4/5] flink-web git commit: Rebuild website - posted by tw...@apache.org on 2018/03/27 15:13:10 UTC, 0 replies.
- flink git commit: [hotfix] [docs] Fix missing license header - posted by tw...@apache.org on 2018/03/27 15:49:46 UTC, 3 replies.
- [1/5] flink git commit: [FLINK-9057][network] fix an NPE when cleaning up before requesting a subpartition view - posted by tr...@apache.org on 2018/03/28 06:11:17 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][tests] add a name to the parameter of RescalingITCase - posted by tr...@apache.org on 2018/03/28 06:11:18 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8941][tests] use TestLogger and TemporaryFolder in SpanningRecordSerializationTest - posted by tr...@apache.org on 2018/03/28 06:11:19 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-8941][serialization] make sure we use unique spilling files - posted by tr...@apache.org on 2018/03/28 06:11:20 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-8415] Unprotected access to recordsToSend in LongRecordWriterThread#shutdown() - posted by tr...@apache.org on 2018/03/28 06:11:21 UTC, 1 replies.
- [1/5] flink git commit: [hotfix][tests] add a name to the parameter of RescalingITCase - posted by tr...@apache.org on 2018/03/28 06:12:24 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-8941][tests] use TestLogger and TemporaryFolder in SpanningRecordSerializationTest - posted by tr...@apache.org on 2018/03/28 06:12:25 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-9057][network] fix an NPE when cleaning up before requesting a subpartition view - posted by tr...@apache.org on 2018/03/28 06:12:26 UTC, 0 replies.
- flink git commit: [hotfix] [test] Move resuming from savepoint e2e tests to nightly tests - posted by tz...@apache.org on 2018/03/28 09:17:28 UTC, 1 replies.
- flink git commit: [FLINK-9026] [flip6] Close the TaskManagerMetricGroup when the TaskExecutor is shut down - posted by tr...@apache.org on 2018/03/28 14:21:33 UTC, 1 replies.
- [1/8] flink git commit: [hotfix] Create ExecutionGraph when JobMaster is started - posted by tr...@apache.org on 2018/03/28 15:24:30 UTC, 1 replies.
- [2/8] flink git commit: [FLINK-8740] [metrics] Create new JobManagerJobMetricGroup when creating a new ExecutionGraph - posted by tr...@apache.org on 2018/03/28 15:24:31 UTC, 1 replies.
- [3/8] flink git commit: [hotfix] Fix race condition in JobMaster#requestJobDetails - posted by tr...@apache.org on 2018/03/28 15:24:32 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] Remove unused fields in JobMaster - posted by tr...@apache.org on 2018/03/28 15:24:33 UTC, 1 replies.
- [5/8] flink git commit: [FLINK-9099] Assign Execution to LogicalSlot when slot is assigned to Execution - posted by tr...@apache.org on 2018/03/28 15:24:34 UTC, 0 replies.
- [6/8] flink git commit: [hotfix] Remove cluttering comments from JobMaster - posted by tr...@apache.org on 2018/03/28 15:24:35 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-8887] Wait for JobMaster leader election in Dispatcher - posted by tr...@apache.org on 2018/03/28 15:24:36 UTC, 1 replies.
- [8/8] flink git commit: [FLINK-9063] Fix SpillableSubpartitionTest testSpillFinishedBufferConsumers - posted by tr...@apache.org on 2018/03/28 15:24:37 UTC, 1 replies.
- [3/8] flink git commit: [hotfix] Remove cluttering comments from JobMaster - posted by tr...@apache.org on 2018/03/28 15:25:47 UTC, 0 replies.
- [5/8] flink git commit: [hotfix] Fix race condition in JobMaster#requestJobDetails - posted by tr...@apache.org on 2018/03/28 15:25:49 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-9099] Assign Execution to LogicalSlot when slot is assigned to Execution - posted by tr...@apache.org on 2018/03/28 15:25:50 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] Extend TestingFatalErrorHandler to return an error future - posted by tr...@apache.org on 2018/03/28 20:15:25 UTC, 1 replies.
- [2/4] flink git commit: [hotfix] Add BiFunctionWithException - posted by tr...@apache.org on 2018/03/28 20:15:26 UTC, 1 replies.
- [3/4] flink git commit: [FLINK-8943] [ha] Fail Dispatcher if jobs cannot be recovered from HA store - posted by tr...@apache.org on 2018/03/28 20:15:27 UTC, 1 replies.
- [4/4] flink git commit: [FLINK-9081] [tests] Harden ResourceManagerJobMasterTest and ResourceManagerTaskExecutorTest - posted by tr...@apache.org on 2018/03/28 20:15:28 UTC, 1 replies.
- flink git commit: [hotfix] Guard against clock changes when computing the net runtime of a job - posted by tr...@apache.org on 2018/03/29 08:35:49 UTC, 1 replies.
- flink git commit: [FLINK-9031] [optimizer] Fix DataSet Union operator translation bug. - posted by se...@apache.org on 2018/03/29 11:54:23 UTC, 2 replies.
- flink git commit: [FLINK-8813][flip6] Disallow PARALLELISM_AUTO_MAX for flip6 - posted by kk...@apache.org on 2018/03/29 12:01:32 UTC, 1 replies.
- flink git commit: [FLINK-9060][state] Fix concurrent modification exception when iterating keys. - posted by kk...@apache.org on 2018/03/29 12:13:47 UTC, 1 replies.
- flink git commit: [FLINK-8708] [examples] Unintended integer division in StandaloneThreadedGenerator - posted by se...@apache.org on 2018/03/29 12:28:33 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-8908] Do not create copy when MapSerializer stateless. - posted by kk...@apache.org on 2018/03/29 15:59:41 UTC, 1 replies.
- [2/5] flink git commit: [FLINK-8928] [QS] Improve server binding error message. - posted by kk...@apache.org on 2018/03/29 15:59:42 UTC, 1 replies.
- [3/5] flink git commit: [FLINK-8926] [QS] Shutdown client proxy after test ends. - posted by kk...@apache.org on 2018/03/29 15:59:43 UTC, 1 replies.
- [4/5] flink git commit: [FLINK-8802] [QS] Fix concurrent access to non-duplicated serializers. - posted by kk...@apache.org on 2018/03/29 15:59:44 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-8802] [QS] Fix concurrent access to non-duplicated serializers. - posted by kk...@apache.org on 2018/03/29 15:59:45 UTC, 1 replies.
- [1/6] flink git commit: [FLINK-9106] [rpc] Add UnfencedMainThreadExecutor to FencedRpcEndpoint - posted by tr...@apache.org on 2018/03/29 16:08:22 UTC, 0 replies.
- [2/6] flink git commit: [hotfix] Add FutureUtils.supplyAsync with SupplierWithException - posted by tr...@apache.org on 2018/03/29 16:08:23 UTC, 1 replies.
- [3/6] flink git commit: [hotfix] Correct JavaDocs in SubmittedJobGraphStore and add Nullable annotation - posted by tr...@apache.org on 2018/03/29 16:08:24 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] Re-introduce FatalErrorHandler to JobManagerRunner - posted by tr...@apache.org on 2018/03/29 16:08:25 UTC, 0 replies.
- [5/6] flink git commit: [FLINK-9097] Fail fatally if job submission fails when recovering jobs - posted by tr...@apache.org on 2018/03/29 16:08:26 UTC, 1 replies.
- [6/6] flink git commit: [hotfix] Recover jobs before setting fencing token - posted by tr...@apache.org on 2018/03/29 16:08:27 UTC, 1 replies.
- [1/6] flink git commit: [hotfix] Re-introduce FatalErrorHandler to JobManagerRunner - posted by tr...@apache.org on 2018/03/29 16:09:41 UTC, 0 replies.
- [3/6] flink git commit: [FLINK-9106] [rpc] Add UnfencedMainThreadExecutor to FencedRpcEndpoint - posted by tr...@apache.org on 2018/03/29 16:09:43 UTC, 0 replies.
- [4/6] flink git commit: [hotfix] Correct JavaDocs in SubmittedJobGraphStore and add Nullable annotation - posted by tr...@apache.org on 2018/03/29 16:09:44 UTC, 0 replies.