commits@flink.apache.org, 2018-02

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

- Jenkins build is back to normal : flink-snapshot-deployment #728 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/01 04:25:24 UTC, 0 replies.
- [01/22] flink git commit: [hotfix] [bin] Adjust the comments and inactive options in 'flink-conf.yaml' to reflect latest config options - posted by se...@apache.org on 2018/02/01 15:46:33 UTC, 0 replies.
- [02/22] flink git commit: [hotfix] [bin] Reorder sections in flink-conf.yaml to reflect common use of options. - posted by se...@apache.org on 2018/02/01 15:46:34 UTC, 0 replies.
- [03/22] flink git commit: [hotfix] [checkpoints] Clean up CompletedCheckpoint, grouping related methods together - posted by se...@apache.org on 2018/02/01 15:46:35 UTC, 0 replies.
- [04/22] flink git commit: [hotfix] [tests] Drop obsolete CheckpointExternalResumeTest. - posted by se...@apache.org on 2018/02/01 15:46:36 UTC, 0 replies.
- [05/22] flink git commit: [hotfix] [checkpointing] Cleanup: Fix Nullability and names in checkpoint stats. - posted by se...@apache.org on 2018/02/01 15:46:37 UTC, 0 replies.
- [06/22] flink git commit: [hotfix] [tests] Clean up HeapKeyedStateBackendAsyncByDefaultTest - posted by se...@apache.org on 2018/02/01 15:46:38 UTC, 0 replies.
- [07/22] flink git commit: [FLINK-8531] [checkpoints] (part 1) Pull CheckpointType into its own class. - posted by se...@apache.org on 2018/02/01 15:46:39 UTC, 0 replies.
- [08/22] flink git commit: [hotfix] [checkpoints] Drop ill-defined hashCode() and equals() from CompletedCheckpoint. - posted by se...@apache.org on 2018/02/01 15:46:40 UTC, 0 replies.
- [09/22] flink git commit: [FLINK-8531] [checkpoints] (part 2) Add CheckpointType to CheckpointProperties - posted by se...@apache.org on 2018/02/01 15:46:41 UTC, 0 replies.
- [10/22] flink git commit: [FLINK-8531] [checkpoints] (part 9) Introduce EXCLUSIVE and SHARED scope for states - posted by se...@apache.org on 2018/02/01 15:46:42 UTC, 0 replies.
- [11/22] flink git commit: [FLINK-8531] [checkpoints] (part 8) Add tests for the FsCheckpointStorage and MemoryBackendCheckpointStorage. - posted by se...@apache.org on 2018/02/01 15:46:43 UTC, 0 replies.
- [12/22] flink git commit: [FLINK-8531] [checkpoints] (part 3) Rework ExternalizedCheckpointITCase - posted by se...@apache.org on 2018/02/01 15:46:44 UTC, 0 replies.
- [13/22] flink git commit: [FLINK-8531] [checkpoints] (part 4) rename forCheckpoint() to forCheckpointWithDefaultLocation() - posted by se...@apache.org on 2018/02/01 15:46:45 UTC, 0 replies.
- [14/22] flink git commit: [FLINK-8531] [checkpoints] (part 5) Introduce CheckpointStorageLocationReference instead of String to communicate the location - posted by se...@apache.org on 2018/02/01 15:46:46 UTC, 0 replies.
- [15/22] flink git commit: [FLINK-8531] [checkpoints] (part 6) Tasks resolve CheckpointStreamFactory from CheckpointStorage and Checkpoint Location Reference to persist checkpoint data. - posted by se...@apache.org on 2018/02/01 15:46:47 UTC, 0 replies.
- [16/22] flink git commit: [FLINK-8531] [checkpoints] (part 6) Tasks resolve CheckpointStreamFactory from CheckpointStorage and Checkpoint Location Reference to persist checkpoint data. - posted by se...@apache.org on 2018/02/01 15:46:48 UTC, 0 replies.
- [17/22] flink git commit: [FLINK-8531] [checkpoints] (part 7) Move tests specific to Checkpoint Storage and Checkpoint Stream to separate tests suites - posted by se...@apache.org on 2018/02/01 15:46:49 UTC, 0 replies.
- [18/22] flink git commit: [FLINK-8539] [checkpointing] (part 3) Rename FixFileFsStateOutputStream to FsCheckpointMetadataOutputStream - posted by se...@apache.org on 2018/02/01 15:46:50 UTC, 0 replies.
- [19/22] flink git commit: [FLINK-8539] [checkpointing] (part 2) Modify all tests to use CompletedCheckpointStorageLocation. - posted by se...@apache.org on 2018/02/01 15:46:51 UTC, 0 replies.
- [20/22] flink git commit: [hotfix] [runtime] Fix checkstyle for 'runtime/io/network/api'. - posted by se...@apache.org on 2018/02/01 15:46:52 UTC, 0 replies.
- [21/22] flink git commit: [FLINK-8539] [checkpointing] (part 1) Introduce CompletedCheckpointStorageLocation to properly handle disposal of checkpoints. - posted by se...@apache.org on 2018/02/01 15:46:53 UTC, 0 replies.
- [22/22] flink git commit: [FLINK-8540] [checkpointing] FileStateHandles no longer attempt to clean up their parent directory. - posted by se...@apache.org on 2018/02/01 15:46:54 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #729 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/02 05:22:01 UTC, 0 replies.
- flink git commit: [hotfix] Fix some typos in flink-conf.yaml comments. - posted by se...@apache.org on 2018/02/02 08:07:46 UTC, 0 replies.
- flink git commit: [hotfix][cep] Remove migration from 1.5 test - posted by dw...@apache.org on 2018/02/02 10:22:23 UTC, 0 replies.
- flink git commit: [hotfix] Simplify computation in KeyGroupRangeAssignment::computeKeyGroupRangeForOperatorIndex - posted by sr...@apache.org on 2018/02/02 13:42:23 UTC, 0 replies.
- flink git commit: [FLINK-8489][ES] Prevent side-effects when modifying user-config - posted by ch...@apache.org on 2018/02/02 14:59:22 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #730 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/03 04:37:03 UTC, 0 replies.
- flink git commit: [FLINK-4812][metrics] Expose currentLowWatermark for all operators - posted by ch...@apache.org on 2018/02/03 06:51:27 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8243] [orc] OrcTableSource reads input path recursively by default. - posted by fh...@apache.org on 2018/02/05 14:58:28 UTC, 1 replies.
- [2/3] flink git commit: [FLINK-8242] [orc] Fix predicate translation if literal is not Serializable. - posted by fh...@apache.org on 2018/02/05 14:58:29 UTC, 1 replies.
- [3/3] flink git commit: [FLINK-8242] [table] RexProgramExtractor only translates literals of known types. - posted by fh...@apache.org on 2018/02/05 14:58:30 UTC, 1 replies.
- flink git commit: [FLINK-8384] [streaming] Dynamic Gap Session Window Assigner - posted by al...@apache.org on 2018/02/05 15:47:19 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [cep] SharedBuffer refactoring. - posted by kk...@apache.org on 2018/02/05 16:20:59 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8561] [cep] Fix SharedBuffer.removeEdges to use .equals(). - posted by kk...@apache.org on 2018/02/05 16:21:00 UTC, 1 replies.
- Build failed in Jenkins: flink-snapshot-deployment #733 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/06 04:03:02 UTC, 0 replies.
- flink git commit: [FLINK-7923] [table] Support accessing fields of arrays of composite types - posted by tw...@apache.org on 2018/02/06 07:30:42 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8555] [table] Simplify function operand checkers and inference - posted by tw...@apache.org on 2018/02/06 09:25:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8555] [table] Fix TableFunction varargs length exceed 254 - posted by tw...@apache.org on 2018/02/06 09:25:51 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8471] [flip6] Introduce configuration switch for Flip-6 - posted by tr...@apache.org on 2018/02/06 11:02:03 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8471] [flip6] Merge Flip-6 and old Mesos start up scripts into one - posted by tr...@apache.org on 2018/02/06 11:02:04 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8493] [flip6] Integrate queryable state with Flip-6 - posted by tr...@apache.org on 2018/02/06 11:02:05 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8495] [flip6] Enable main cluster component's log and stdout file retrieval - posted by tr...@apache.org on 2018/02/06 11:02:06 UTC, 0 replies.
- flink git commit: [FLINK-8559][RocksDB] Release resources if snapshot operation fails - posted by ch...@apache.org on 2018/02/06 13:13:59 UTC, 0 replies.
- [01/11] flink git commit: [FLINK-8501] [flip6] Use single BlobCacheService per TaskExecutor - posted by tr...@apache.org on 2018/02/06 16:53:16 UTC, 0 replies.
- [02/11] flink git commit: [FLINK-8501] [flip6] Use single BlobCacheService per TaskExecutor - posted by tr...@apache.org on 2018/02/06 16:53:17 UTC, 0 replies.
- [03/11] flink git commit: [FLINK-8502] [flip6] Remove LibraryCacheManager from JobMaster - posted by tr...@apache.org on 2018/02/06 16:53:18 UTC, 0 replies.
- [04/11] flink git commit: [hotfix] [tests] Remove JobManagerRunnerMockTest - posted by tr...@apache.org on 2018/02/06 16:53:19 UTC, 0 replies.
- [05/11] flink git commit: [FLINK-8503] [flip6] Display TaskExecutor logs and stdout files in web ui - posted by tr...@apache.org on 2018/02/06 16:53:20 UTC, 0 replies.
- [06/11] flink git commit: [FLINK-8503] [flip6] Display TaskExecutor logs and stdout files in web ui - posted by tr...@apache.org on 2018/02/06 16:53:21 UTC, 0 replies.
- [07/11] flink git commit: [hotfix] Return NOT_FOUND in TaskManagerDetailsHandler if TaskExecutor unknown - posted by tr...@apache.org on 2018/02/06 16:53:22 UTC, 0 replies.
- [08/11] flink git commit: [FLINK-7856][flip6] Port JobVertexBackPressureHandler to REST endpoint - posted by tr...@apache.org on 2018/02/06 16:53:23 UTC, 0 replies.
- [09/11] flink git commit: [FLINK-7856][flip6] Port JobVertexBackPressureHandler to REST endpoint - posted by tr...@apache.org on 2018/02/06 16:53:24 UTC, 0 replies.
- [10/11] flink git commit: [hotfix][tests] Add Javadocs to JobMasterTest - posted by tr...@apache.org on 2018/02/06 16:53:25 UTC, 0 replies.
- [11/11] flink git commit: [hotfix] Log swallowed exception in JobMaster - posted by tr...@apache.org on 2018/02/06 16:53:26 UTC, 0 replies.
- [01/31] flink git commit: [FLINK-8472] [DataStream, test] Refactor StatefulJobSavepointFrom*MigrationITCase to single ITCase - posted by tz...@apache.org on 2018/02/06 19:02:25 UTC, 0 replies.
- [02/31] flink git commit: [hotfix] [kafka] Fix inapproriate access modifiers in AbstractFetcher - posted by tz...@apache.org on 2018/02/06 19:02:26 UTC, 0 replies.
- [03/31] flink git commit: [FLINK-8409] [kafka] Fix offset committing race condition in KafkaConsumerThread - posted by tz...@apache.org on 2018/02/06 19:02:27 UTC, 0 replies.
- [04/31] flink git commit: [FLINK-8398] [kinesis, tests] Stabilize flaky KinesisDataFetcherTests - posted by tz...@apache.org on 2018/02/06 19:02:28 UTC, 0 replies.
- [05/31] flink git commit: [FLINK-8398] [kinesis, tests] Cleanup confusing implementations in KinesisDataFetcherTest and related classes - posted by tz...@apache.org on 2018/02/06 19:02:29 UTC, 0 replies.
- [06/31] flink git commit: [FLINK-6004] [kinesis] Allow FlinkKinesisConsumer to skip records - posted by tz...@apache.org on 2018/02/06 19:02:30 UTC, 0 replies.
- [07/31] flink git commit: [FLINK-8419] [kafka] Register metrics for dynamically discovered Kafka partitions - posted by tz...@apache.org on 2018/02/06 19:02:31 UTC, 0 replies.
- [08/31] flink git commit: [FLINK-8419] [kafka] Move consumer metric group registration to FlinkKafkaConsumerBase - posted by tz...@apache.org on 2018/02/06 19:02:32 UTC, 0 replies.
- [09/31] flink git commit: [hotfix] [kafka] Make AbortedReassignmentException a static class - posted by tz...@apache.org on 2018/02/06 19:02:33 UTC, 0 replies.
- [10/31] flink git commit: [FLINK-8472] [scala, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:34 UTC, 0 replies.
- [11/31] flink git commit: [hotfix] [kinesis, test] Use real test classes instead of Mockito in FlinkKinesisConsumerMigrationTest - posted by tz...@apache.org on 2018/02/06 19:02:35 UTC, 0 replies.
- [12/31] flink git commit: [hotfix][connectors] Fix log format strings - posted by tz...@apache.org on 2018/02/06 19:02:36 UTC, 0 replies.
- [13/31] flink git commit: [FLINK-8022][kafka-tests] Disable at-least-once tests for Kafka 0.9 - posted by tz...@apache.org on 2018/02/06 19:02:37 UTC, 0 replies.
- [14/31] flink git commit: [FLINK-8484] [kinesis] Synchronize local shard metainfo's on restore - posted by tz...@apache.org on 2018/02/06 19:02:38 UTC, 0 replies.
- [15/31] flink git commit: [FLINK-8472] [DataStream, test] Extend WindowOperatorMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:39 UTC, 0 replies.
- [16/31] flink git commit: [hotfix] [kinesis] Use ArrayList for faster shard state updates - posted by tz...@apache.org on 2018/02/06 19:02:40 UTC, 0 replies.
- [17/31] flink git commit: [FLINK-8484] [kinesis] Use an equivalence wrapper around restored StreamShardMetadatas to bypass out-of-sync shard infos - posted by tz...@apache.org on 2018/02/06 19:02:41 UTC, 0 replies.
- [18/31] flink git commit: [FLINK-8421] [DataStream, tests] Add WindowOperator migration test for Kryo-serialized window keys - posted by tz...@apache.org on 2018/02/06 19:02:42 UTC, 0 replies.
- [19/31] flink git commit: [FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka framesize in AbstractEventTimeWindowCheckpointingITCase - posted by tz...@apache.org on 2018/02/06 19:02:43 UTC, 0 replies.
- [20/31] flink git commit: [FLINK-8472] [DataStream, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:44 UTC, 0 replies.
- [21/31] flink git commit: [FLINK-8472] [kafka, test] Extend FlinkKafkaConsumerBaseMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:45 UTC, 0 replies.
- [22/31] flink git commit: [FLINK-8421] [core] Allow InstantiationUtil.deserializeObject() to use FailureTolerantObjectInputStream - posted by tz...@apache.org on 2018/02/06 19:02:46 UTC, 0 replies.
- [23/31] flink git commit: [FLINK-8275] [security, yarn] Remove test-specific code path in YarnTaskManagerRunner - posted by tz...@apache.org on 2018/02/06 19:02:47 UTC, 0 replies.
- [24/31] flink git commit: [hotfix] [test] Remove stale savepoint files no longer used by migration tests - posted by tz...@apache.org on 2018/02/06 19:02:48 UTC, 0 replies.
- [25/31] flink git commit: [FLINK-8472] [fs, test] Extend BucketingSinkMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:49 UTC, 0 replies.
- [26/31] flink git commit: [FLINK-8421] [DataStream] Make timer serializers reconfigurable on restore - posted by tz...@apache.org on 2018/02/06 19:02:50 UTC, 0 replies.
- [27/31] flink git commit: [FLINK-8472] [kinesis, test] Extend FlinkKinesisConsumerMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:51 UTC, 0 replies.
- [28/31] flink git commit: [FLINK-8275] [security, yarn] Fix keytab local path in YarnTaskManagerRunner - posted by tz...@apache.org on 2018/02/06 19:02:52 UTC, 0 replies.
- [29/31] flink git commit: [FLINK-8421] [core] Introduce PostVersionedIOReadableWritable - posted by tz...@apache.org on 2018/02/06 19:02:53 UTC, 0 replies.
- [30/31] flink git commit: [FLINK-8472] [fs, test] Extend ContinuousFileProcessingMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:54 UTC, 0 replies.
- [31/31] flink git commit: [FLINK-8472] [tests] Extend AbstractOperatorRestoreTestBases for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:02:55 UTC, 0 replies.
- [01/28] flink git commit: [FLINK-8421] [core] Allow InstantiationUtil.deserializeObject() to use FailureTolerantObjectInputStream - posted by tz...@apache.org on 2018/02/06 19:03:01 UTC, 0 replies.
- [02/28] flink git commit: [FLINK-8421] [DataStream, tests] Add WindowOperator migration test for Kryo-serialized window keys - posted by tz...@apache.org on 2018/02/06 19:03:02 UTC, 0 replies.
- [03/28] flink git commit: [FLINK-8472] [DataStream, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:03 UTC, 0 replies.
- [04/28] flink git commit: [FLINK-8472] [DataStream, test] Refactor StatefulJobSavepointFrom*MigrationITCase to single ITCase - posted by tz...@apache.org on 2018/02/06 19:03:04 UTC, 0 replies.
- [05/28] flink git commit: [FLINK-8409] [kafka] Fix offset committing race condition in KafkaConsumerThread - posted by tz...@apache.org on 2018/02/06 19:03:05 UTC, 0 replies.
- [06/28] flink git commit: [hotfix] [kafka] Make AbortedReassignmentException a static class - posted by tz...@apache.org on 2018/02/06 19:03:06 UTC, 0 replies.
- [07/28] flink git commit: [FLINK-8419] [kafka] Move consumer metric group registration to FlinkKafkaConsumerBase - posted by tz...@apache.org on 2018/02/06 19:03:07 UTC, 0 replies.
- [08/28] flink git commit: [FLINK-8419] [kafka] Register metrics for dynamically discovered Kafka partitions - posted by tz...@apache.org on 2018/02/06 19:03:08 UTC, 0 replies.
- [09/28] flink git commit: [FLINK-8398] [kinesis, tests] Cleanup confusing implementations in KinesisDataFetcherTest and related classes - posted by tz...@apache.org on 2018/02/06 19:03:09 UTC, 0 replies.
- [10/28] flink git commit: [FLINK-8398] [kinesis, tests] Stabilize flaky KinesisDataFetcherTests - posted by tz...@apache.org on 2018/02/06 19:03:10 UTC, 0 replies.
- [11/28] flink git commit: [FLINK-8484] [kinesis] Synchronize local shard metainfo's on restore - posted by tz...@apache.org on 2018/02/06 19:03:11 UTC, 0 replies.
- [12/28] flink git commit: [FLINK-8472] [kafka, test] Extend FlinkKafkaConsumerBaseMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:12 UTC, 0 replies.
- [13/28] flink git commit: [FLINK-8472] [kinesis, test] Extend FlinkKinesisConsumerMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:13 UTC, 0 replies.
- [14/28] flink git commit: [FLINK-8484] [kinesis] Use an equivalence wrapper around restored StreamShardMetadatas to bypass out-of-sync shard infos - posted by tz...@apache.org on 2018/02/06 19:03:14 UTC, 0 replies.
- [15/28] flink git commit: [hotfix][connectors] Fix log format strings - posted by tz...@apache.org on 2018/02/06 19:03:15 UTC, 0 replies.
- [16/28] flink git commit: [FLINK-8472] [DataStream, test] Extend WindowOperatorMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:16 UTC, 0 replies.
- [17/28] flink git commit: [hotfix] [test] Remove stale savepoint files no longer used by migration tests - posted by tz...@apache.org on 2018/02/06 19:03:17 UTC, 0 replies.
- [18/28] flink git commit: [FLINK-8472] [fs, test] Extend BucketingSinkMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:18 UTC, 0 replies.
- [19/28] flink git commit: [FLINK-8472] [fs, test] Extend ContinuousFileProcessingMigrationTest for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:19 UTC, 0 replies.
- [20/28] flink git commit: [hotfix] [kinesis, test] Use real test classes instead of Mockito in FlinkKinesisConsumerMigrationTest - posted by tz...@apache.org on 2018/02/06 19:03:20 UTC, 0 replies.
- [21/28] flink git commit: [FLINK-8472] [tests] Extend AbstractOperatorRestoreTestBases for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:21 UTC, 0 replies.
- [22/28] flink git commit: [hotfix] [kinesis] Use ArrayList for faster shard state updates - posted by tz...@apache.org on 2018/02/06 19:03:22 UTC, 0 replies.
- [23/28] flink git commit: [FLINK-8472] [scala, test] Extend StatefulJobSavepointMigrationITCase for Flink 1.4 - posted by tz...@apache.org on 2018/02/06 19:03:23 UTC, 0 replies.
- [24/28] flink git commit: [FLINK-8421] [core] Introduce PostVersionedIOReadableWritable - posted by tz...@apache.org on 2018/02/06 19:03:24 UTC, 0 replies.
- [25/28] flink git commit: [FLINK-8421] [DataStream] Make timer serializers reconfigurable on restore - posted by tz...@apache.org on 2018/02/06 19:03:25 UTC, 0 replies.
- [26/28] flink git commit: [FLINK-8421] [test] Increase MAX_MEM_STATE_SIZE and Akka framesize in AbstractEventTimeWindowCheckpointingITCase - posted by tz...@apache.org on 2018/02/06 19:03:26 UTC, 0 replies.
- [27/28] flink git commit: [FLINK-8275] [security, yarn] Fix keytab local path in YarnTaskManagerRunner - posted by tz...@apache.org on 2018/02/06 19:03:27 UTC, 0 replies.
- [28/28] flink git commit: [FLINK-8275] [security, yarn] Remove test-specific code path in YarnTaskManagerRunner - posted by tz...@apache.org on 2018/02/06 19:03:28 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-8559][RocksDB] Release resources if snapshot operation fails - posted by ch...@apache.org on 2018/02/06 21:24:15 UTC, 0 replies.
- [2/8] flink git commit: [hotfix][docs] Fix typos in window document - posted by ch...@apache.org on 2018/02/06 21:24:16 UTC, 0 replies.
- [3/8] flink git commit: [hotfix][build] Fix duplicate maven enforce plugin declaration - posted by ch...@apache.org on 2018/02/06 21:24:17 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-8550][table] Iterate over entryset instead of keys - posted by ch...@apache.org on 2018/02/06 21:24:18 UTC, 0 replies.
- [5/8] flink git commit: [hotfix][docs] Fix typos - posted by ch...@apache.org on 2018/02/06 21:24:19 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-7608][metrics] Rework latency metric - posted by ch...@apache.org on 2018/02/06 21:24:20 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-7803][docs] Add missing savepoint information - posted by ch...@apache.org on 2018/02/06 21:24:21 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-8565][tests] Ensure locationBytes.length > 0 - posted by ch...@apache.org on 2018/02/06 21:24:22 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #734 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/07 04:16:56 UTC, 0 replies.
- [1/2] flink git commit: [hotfix][tests] Fix compiler warning in MetricFetcherTest - posted by ch...@apache.org on 2018/02/07 10:42:48 UTC, 0 replies.
- [2/2] flink git commit: [hotfix][metrics] Restrict visiblity of testing methods in Slf4jReporter - posted by ch...@apache.org on 2018/02/07 10:42:49 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-8522] [checkpoint] Remove number of states from checkpoint. - posted by kk...@apache.org on 2018/02/07 13:10:33 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-4940] Add broadcast state to the OperatorStateBackend. - posted by kk...@apache.org on 2018/02/07 13:10:34 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-4940] Add broadcast state to the OperatorStateBackend. - posted by kk...@apache.org on 2018/02/07 13:10:35 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-3659] Expose broadcast state on DataStream API. - posted by kk...@apache.org on 2018/02/07 13:10:36 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-3659] Expose broadcast state on DataStream API. - posted by kk...@apache.org on 2018/02/07 13:10:37 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8345] Add iterator of keyed state on broadcast side of connected streams. - posted by kk...@apache.org on 2018/02/07 13:10:38 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-8446] Support multiple broadcast states. - posted by kk...@apache.org on 2018/02/07 13:10:39 UTC, 0 replies.
- [8/8] flink git commit: [hotfix] Create BroadcastITCase. - posted by kk...@apache.org on 2018/02/07 13:10:40 UTC, 0 replies.
- flink git commit: [FLINK-8595] [table] Include table source factory services in flink-table jar - posted by tw...@apache.org on 2018/02/07 14:43:26 UTC, 0 replies.
- [1/2] flink-web git commit: Add Incremental Checkpointing blog post - posted by fh...@apache.org on 2018/02/07 17:56:26 UTC, 0 replies.
- [2/2] flink-web git commit: Rebuild website - posted by fh...@apache.org on 2018/02/07 17:56:27 UTC, 0 replies.
- flink git commit: [FLINK-7760] Fix deserialization of NFA state in CEP library - posted by al...@apache.org on 2018/02/07 19:01:41 UTC, 1 replies.
- Build failed in Jenkins: flink-snapshot-deployment #735 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/08 04:03:32 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8575][runtime] Add missing synchronization in BackPressureStatsTracker - posted by tr...@apache.org on 2018/02/08 13:54:48 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8575][runtime] Add missing synchronization in BackPressureStatsTracker - posted by tr...@apache.org on 2018/02/08 13:54:49 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8362] [elasticsearch] Further improvements for Elasticsearch connector shading - posted by tz...@apache.org on 2018/02/08 16:18:06 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8362][elasticsearch] shade all dependencies - posted by tz...@apache.org on 2018/02/08 16:18:07 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8362][elasticsearch] shade all dependencies - posted by tz...@apache.org on 2018/02/08 16:21:43 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8362] [elasticsearch] Further improvements for Elasticsearch connector shading - posted by tz...@apache.org on 2018/02/08 16:21:44 UTC, 0 replies.
- svn commit: r24833 - /release/flink/KEYS - posted by tz...@apache.org on 2018/02/08 17:24:18 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #736 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/09 04:14:02 UTC, 0 replies.
- flink git commit: [FLINK-8571] [DataStream] Introduce utility function that reinterprets a data stream as keyed stream (backport from 1.5 branch) - posted by sr...@apache.org on 2018/02/09 16:36:43 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8456] Add Scala API for Connected Streams with Broadcast State. - posted by kk...@apache.org on 2018/02/09 17:17:01 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8597] Add examples for Connected Streams with Broadcast State. - posted by kk...@apache.org on 2018/02/09 17:17:02 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8571] [DataStream] Introduce utility function that reinterprets a data stream as keyed stream - posted by sr...@apache.org on 2018/02/09 17:23:51 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Move DataStreamUtils to the datastream API package so that we can actually use it to expose package-private constructors or methods for experimental features. - posted by sr...@apache.org on 2018/02/09 17:23:52 UTC, 0 replies.
- [flink] Git Push Summary - posted by tz...@apache.org on 2018/02/10 14:04:11 UTC, 3 replies.
- [1/3] flink git commit: [FLINK-7124] [flip6] Add test to verify rescaling JobGraphs works correctly - posted by tr...@apache.org on 2018/02/10 22:49:42 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-7124] [flip6] Introduce parallelism <= max parallelism check into ExecutionJobVertex - posted by tr...@apache.org on 2018/02/10 22:49:43 UTC, 0 replies.
- [3/3] flink git commit: [hotfix] Refactor graph verification code in ExecutionGraphConstructionTest - posted by tr...@apache.org on 2018/02/10 22:49:44 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #739 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/12 04:02:44 UTC, 0 replies.
- flink git commit: [FLINK-8617] [table] Fix code generation bug while accessing Map type - posted by tw...@apache.org on 2018/02/12 09:49:03 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] Simplify TaskExecutorTest to avoid Mockito - posted by tr...@apache.org on 2018/02/12 14:50:32 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-8636] [flip6] Use TaskManagerServices to pass in services to TaskExecutor - posted by tr...@apache.org on 2018/02/12 14:50:33 UTC, 0 replies.
- [3/5] flink git commit: [hotfix][kafka-tests] Do not hide original exception in FlinkKafkaProducer011ITCase - posted by tr...@apache.org on 2018/02/12 14:50:34 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7871] [flip6] SlotPool should release unused slots to RM - posted by tr...@apache.org on 2018/02/12 14:50:35 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7871] [flip6] Add ManualClock for SlotPool slot release tests - posted by tr...@apache.org on 2018/02/12 14:50:36 UTC, 0 replies.
- [01/10] flink git commit: [FLINK-8475][config][docs] Integrate Algorithm options - posted by ch...@apache.org on 2018/02/12 17:50:49 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-8475][config][docs] Integrate Mesos options - posted by ch...@apache.org on 2018/02/12 17:50:50 UTC, 0 replies.
- [03/10] flink git commit: [FLINK-8475][config][docs] Integrate netty options - posted by ch...@apache.org on 2018/02/12 17:50:51 UTC, 0 replies.
- [04/10] flink git commit: [FLINK-8475][config][docs] Integrate optimizer options - posted by ch...@apache.org on 2018/02/12 17:50:52 UTC, 0 replies.
- [05/10] flink git commit: [FLINK-8475][config][docs] Integrate REST options - posted by ch...@apache.org on 2018/02/12 17:50:53 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-8475][config][docs] Integrate SlotManager options - posted by ch...@apache.org on 2018/02/12 17:50:54 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-8475][config][docs] Integrate BlobServer options - posted by ch...@apache.org on 2018/02/12 17:50:55 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-8475][config][docs] Integrate JM options - posted by ch...@apache.org on 2018/02/12 17:50:56 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-8475][config][docs] Integrate Checkpointing options - posted by ch...@apache.org on 2018/02/12 17:50:57 UTC, 0 replies.
- [10/10] flink git commit: [FLINK-8475][config][docs] Integrate SSL options - posted by ch...@apache.org on 2018/02/12 17:50:58 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #740 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/13 04:14:46 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8626] Introduce BackPressureStatsTracker interface - posted by tr...@apache.org on 2018/02/13 07:51:13 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8637] [flip6] Use JobManagerSharedServices to pass in services to JobMaster - posted by tr...@apache.org on 2018/02/13 07:51:14 UTC, 0 replies.
- flink git commit: [FLINK-8423] OperatorChain#pushToOperator catch block may fail with NPE - posted by ch...@apache.org on 2018/02/13 08:52:48 UTC, 1 replies.
- [1/2] flink git commit: [FLINK-8475][config][docs] Integrate HA-ZK options - posted by ch...@apache.org on 2018/02/13 11:46:09 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8475][config][docs] Integrate YARN options - posted by ch...@apache.org on 2018/02/13 11:46:10 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8642] Initialize descriptors before use at getBroadcastState(). - posted by kk...@apache.org on 2018/02/13 16:34:31 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Clean broadcast functions when translating. - posted by kk...@apache.org on 2018/02/13 16:34:32 UTC, 0 replies.
- Build failed in Jenkins: flink-snapshot-deployment #741 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/14 04:42:32 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-8475][config][docs] Integrate FS options - posted by ch...@apache.org on 2018/02/14 12:56:13 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-8475][config][docs] Integrate HA options - posted by ch...@apache.org on 2018/02/14 12:56:14 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-8475][config][docs] Integrate Environment options - posted by ch...@apache.org on 2018/02/14 12:56:15 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-8475][config][docs] Integrate RM options - posted by ch...@apache.org on 2018/02/14 12:56:16 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-8475][config][docs] Integrate TM options - posted by ch...@apache.org on 2018/02/14 12:56:17 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8475][config][docs] Integrate Core options - posted by ch...@apache.org on 2018/02/14 12:56:18 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-8576][QS] Reduce verbosity when classes can't be found - posted by ch...@apache.org on 2018/02/14 12:56:19 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-8553][metrics][datadog] Switch to async mode - posted by ch...@apache.org on 2018/02/14 12:56:20 UTC, 0 replies.
- flink git commit: [hotfix] Remove costly logging statements from CEP SharedBuffer - posted by al...@apache.org on 2018/02/14 16:47:54 UTC, 0 replies.
- flink git commit: [hotfix] Remove costly checkState() statements from CEP SharedBuffer - posted by al...@apache.org on 2018/02/14 16:53:41 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8652] [QS] Reduce log level in getKvState to DEBUG. - posted by fh...@apache.org on 2018/02/14 19:13:39 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-7658] [table] Add Collect aggregate function to Table API. - posted by fh...@apache.org on 2018/02/14 19:13:40 UTC, 0 replies.
- flink git commit: [FLINK-8652] [QS] Reduce log level in getKvState to DEBUG. - posted by fh...@apache.org on 2018/02/14 19:16:08 UTC, 0 replies.
- buildbot failure in on flink-docs-master - posted by bu...@apache.org on 2018/02/15 00:08:26 UTC, 1 replies.
- Build failed in Jenkins: flink-snapshot-deployment #742 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/15 03:49:25 UTC, 0 replies.
- flink git commit: [hotfix] Remove unused imports from SharedBuffer - posted by tr...@apache.org on 2018/02/15 07:26:02 UTC, 0 replies.
- flink git commit: [hotfix] Remove more checkState() calls from SharedBuffer serialization - posted by al...@apache.org on 2018/02/15 09:21:30 UTC, 0 replies.
- [01/22] flink git commit: [FLINK-8603] [flip6] Split submitJob into job submission and execution result retrieval - posted by tr...@apache.org on 2018/02/15 10:42:44 UTC, 0 replies.
- [02/22] flink git commit: [FLINK-8529] [flip6] Let Yarn entry points use APPLICATION_MASTER_PORT - posted by tr...@apache.org on 2018/02/15 10:42:45 UTC, 0 replies.
- [03/22] flink git commit: [FLINK-8605] [rest] Enable job cancellation from the web UI - posted by tr...@apache.org on 2018/02/15 10:42:46 UTC, 0 replies.
- [04/22] flink git commit: [FLINK-8605] [rest] Enable job cancellation from the web UI - posted by tr...@apache.org on 2018/02/15 10:42:47 UTC, 0 replies.
- [05/22] flink git commit: [FLINK-8605] [rest] Enable job cancellation from the web UI - posted by tr...@apache.org on 2018/02/15 10:42:48 UTC, 0 replies.
- [06/22] flink git commit: [FLINK-8605] [rest] Enable job cancellation from the web UI - posted by tr...@apache.org on 2018/02/15 10:42:49 UTC, 0 replies.
- [07/22] flink git commit: [hotfix] Change shutdown order in WebMonitorEndpoint to avoid illegal state - posted by tr...@apache.org on 2018/02/15 10:42:50 UTC, 0 replies.
- [08/22] flink git commit: [FLINK-8604] [rest] Move JobTerminationHandler into WebMonitorEndpoint - posted by tr...@apache.org on 2018/02/15 10:42:51 UTC, 0 replies.
- [09/22] flink git commit: [FLINK-8609] [flip6] Enable Flip-6 job mode in CliFrontend - posted by tr...@apache.org on 2018/02/15 10:42:52 UTC, 0 replies.
- [10/22] flink git commit: [FLINK-8608] [flip6] Implement MiniDispatcher for job mode - posted by tr...@apache.org on 2018/02/15 10:42:53 UTC, 0 replies.
- [11/22] flink git commit: [FLINK-8608] [flip6] Implement MiniDispatcher for job mode - posted by tr...@apache.org on 2018/02/15 10:42:54 UTC, 0 replies.
- [12/22] flink git commit: [FLINK-8613] [flip6] [yarn] Return excess containers - posted by tr...@apache.org on 2018/02/15 10:42:55 UTC, 0 replies.
- [13/22] flink git commit: [FLINK-8212] [network] Pull EnvironmentInformation out of TaskManagerServices - posted by tr...@apache.org on 2018/02/15 10:42:56 UTC, 0 replies.
- [14/22] flink git commit: [FLINK-7713][flip6] Implement JarUploadHandler - posted by tr...@apache.org on 2018/02/15 10:42:57 UTC, 0 replies.
- [15/22] flink git commit: [FLINK-7713][flip6] Implement JarUploadHandler - posted by tr...@apache.org on 2018/02/15 10:42:58 UTC, 0 replies.
- [16/22] flink git commit: [FLINK-7713][flip6] Implement JarUploadHandler - posted by tr...@apache.org on 2018/02/15 10:42:59 UTC, 0 replies.
- [17/22] flink git commit: [FLINK-8530] [flip6] Enable detached job mode submission to session cluster - posted by tr...@apache.org on 2018/02/15 10:43:00 UTC, 0 replies.
- [18/22] flink git commit: [FLINK-8644] [flip6] Shut down AkkaRpcActors with PoisonPill - posted by tr...@apache.org on 2018/02/15 10:43:01 UTC, 0 replies.
- [19/22] flink git commit: [FLINK-8643] [flip6] Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph - posted by tr...@apache.org on 2018/02/15 10:43:02 UTC, 0 replies.
- [20/22] flink git commit: [FLINK-8643] [flip6] Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph - posted by tr...@apache.org on 2018/02/15 10:43:03 UTC, 0 replies.
- [21/22] flink git commit: [FLINK-8643] [flip6] Use JobManagerOptions#SLOT_REQUEST_TIMEOUT in ExecutionGraph - posted by tr...@apache.org on 2018/02/15 10:43:04 UTC, 0 replies.
- [22/22] flink git commit: [hotfix] [flip6] Remove unnecessary timeout from SlotPool - posted by tr...@apache.org on 2018/02/15 10:43:05 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8303] Add hawkins back to Gemfile - posted by uc...@apache.org on 2018/02/15 11:07:30 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8308] Remove explicit yajl-ruby dependency, update Jekyll to 3+ - posted by uc...@apache.org on 2018/02/15 11:07:31 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8303] [docs] Allow to overwrite ruby/gem binary - posted by uc...@apache.org on 2018/02/15 11:07:32 UTC, 1 replies.
- svn commit: r25085 - /release/flink/flink-1.4.1/ - posted by tz...@apache.org on 2018/02/15 12:51:41 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8401] [cassandra] Add callback methods for failed and successful writes to CassandraOutputFormatBase. - posted by fh...@apache.org on 2018/02/15 13:29:36 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8397] [cassandra] Add CassandraRowOutputFormat. - posted by fh...@apache.org on 2018/02/15 13:29:37 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8647] [flip6] Introduce JobMasterConfiguration - posted by tr...@apache.org on 2018/02/15 16:38:40 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8610] [flip6] Remove RestfulGateway from JobMasterGateway - posted by tr...@apache.org on 2018/02/15 16:38:41 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8611] [flip6] Add result future to JobManagerRunner - posted by tr...@apache.org on 2018/02/15 16:38:42 UTC, 0 replies.
- [4/4] flink git commit: [hotfix] Fix checkstyle violations in JobExecutionResult - posted by tr...@apache.org on 2018/02/15 16:38:43 UTC, 0 replies.
- [1/3] flink-web git commit: Add Flink 1.4.1 release - posted by tz...@apache.org on 2018/02/15 17:42:30 UTC, 0 replies.
- [2/3] flink-web git commit: Rebuild website - posted by tz...@apache.org on 2018/02/15 17:42:31 UTC, 0 replies.
- [3/3] flink-web git commit: Rebuild website - posted by tz...@apache.org on 2018/02/15 17:42:32 UTC, 0 replies.
- buildbot success in on flink-docs-master - posted by bu...@apache.org on 2018/02/15 18:18:23 UTC, 0 replies.
- flink git commit: [FLINK-8516] [kinesis] Allow for custom hash function for shard to subtask mapping in Kinesis consumer - posted by tz...@apache.org on 2018/02/15 18:21:52 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8630] [formats] Add proper support for JSON formats - posted by tw...@apache.org on 2018/02/15 19:18:15 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8630] [formats] Add proper support for JSON formats - posted by tw...@apache.org on 2018/02/15 19:18:16 UTC, 0 replies.
- Jenkins build is back to normal : flink-snapshot-deployment #743 - posted by Apache Jenkins Server <je...@builds.apache.org> on 2018/02/16 04:16:07 UTC, 0 replies.
- flink git commit: [FLINK-8520][cassandra] Fix race condition - posted by ch...@apache.org on 2018/02/16 08:02:23 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8520][cassandra] Fix race condition - posted by ch...@apache.org on 2018/02/16 08:03:50 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8576][QS] Reduce verbosity when classes can't be found - posted by ch...@apache.org on 2018/02/16 08:03:51 UTC, 0 replies.
- flink git commit: [FLINK-5728] [kafka] Let FlinkKafkaProducers flush on checkpoints by default - posted by al...@apache.org on 2018/02/16 08:39:54 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8308] Remove explicit yajl-ruby dependency, update Jekyll to 3+ - posted by uc...@apache.org on 2018/02/16 08:52:47 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8303] Add hawkins back to Gemfile - posted by uc...@apache.org on 2018/02/16 08:52:48 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-3655] [core] Add support for multiple file paths for FileInputFormat. - posted by fh...@apache.org on 2018/02/16 11:19:16 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-3655] [core] Add support for multiple file paths for FileInputFormat. - posted by fh...@apache.org on 2018/02/16 11:19:17 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-8425][network] fix SpilledSubpartitionView not protected against concurrent release calls - posted by sr...@apache.org on 2018/02/16 12:55:54 UTC, 0 replies.
- [2/5] flink git commit: [hotfix] Add the switch for keeping both the old mode and the new credit-based mode - posted by sr...@apache.org on 2018/02/16 12:55:55 UTC, 0 replies.
- [3/5] flink git commit: [hotfix] Add the switch for keeping both the old mode and the new credit-based mode - posted by sr...@apache.org on 2018/02/16 12:55:56 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7456][network] Implement Netty sender incoming pipeline for credit-based - posted by sr...@apache.org on 2018/02/16 12:55:57 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-7456][network] Implement Netty sender incoming pipeline for credit-based - posted by sr...@apache.org on 2018/02/16 12:55:58 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8671][docs] Word-wrap default values - posted by ch...@apache.org on 2018/02/16 13:42:52 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8671][docs] Word-wrap default values - posted by ch...@apache.org on 2018/02/16 13:42:53 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8475][config][docs] Integrate HeartbeatManager options - posted by ch...@apache.org on 2018/02/16 13:42:54 UTC, 0 replies.
- flink git commit: [FLINK-8676] Ensure key stream is closed after backend#applyToAllKeys(). - posted by kk...@apache.org on 2018/02/16 18:23:16 UTC, 0 replies.
- flink git commit: [hotfix][config][docs] Remove leading space from descriptions - posted by ch...@apache.org on 2018/02/16 21:33:08 UTC, 0 replies.
- flink git commit: [FLINK-8411] Don't allow null in ListState.add()/addAll() - posted by al...@apache.org on 2018/02/17 07:34:15 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8607] [table] Add a basic embedded SQL CLI client - posted by tw...@apache.org on 2018/02/17 08:19:20 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8607] [table] Add a basic embedded SQL CLI client - posted by tw...@apache.org on 2018/02/17 08:19:21 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8607] [table] Add a basic embedded SQL CLI client - posted by tw...@apache.org on 2018/02/17 08:19:22 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-7711][flip6] Implement JarListHandler - posted by tr...@apache.org on 2018/02/17 10:17:41 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-7857][flip6] Port JobVertexDetailsHandler to REST endpoint - posted by tr...@apache.org on 2018/02/17 10:17:42 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8612] [flip6] Enable non-detached job mode - posted by tr...@apache.org on 2018/02/17 10:17:43 UTC, 0 replies.
- [4/5] flink git commit: [FLINK-7857][flip6] Return status 404 if JobVertex is unknown - posted by tr...@apache.org on 2018/02/17 10:17:44 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8662] [tests] Harden FutureUtilsTest#testRetryWithDelay - posted by tr...@apache.org on 2018/02/17 10:17:45 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-5886][py] Add Python Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:39 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-5886][py] Add Python Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:40 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-5886][py] Add Python Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:41 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-5886][py] Add Python Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:42 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-5886][py] Various refactorings to Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:43 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-5886][py] Various refactorings to Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:44 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-5886][py] Various refactorings to Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:45 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-5886][py] Various refactorings to Streaming API - posted by ch...@apache.org on 2018/02/17 16:42:46 UTC, 0 replies.
- [1/9] flink git commit: [hotfix] [yarn] Write number of slots to configuration - posted by tr...@apache.org on 2018/02/18 09:13:54 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8673] [flip6] Use JobManagerRunner#resultFuture for success and failure communication - posted by tr...@apache.org on 2018/02/18 09:13:55 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] [yarn] Remove unnecessary TaskManager configuration generation - posted by tr...@apache.org on 2018/02/18 09:13:56 UTC, 0 replies.
- [4/9] flink git commit: [hotfix] Only log retrying exception on debug in RetryingRegistration - posted by tr...@apache.org on 2018/02/18 09:13:57 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-8653] [flip6] Remove internal slot request timeout from SlotPool - posted by tr...@apache.org on 2018/02/18 09:13:58 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-8614] [flip6] Activate Flip-6 mode per default - posted by tr...@apache.org on 2018/02/18 09:13:59 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Initialize FileSystem in TaskManagerRunner#main - posted by tr...@apache.org on 2018/02/18 09:14:00 UTC, 0 replies.
- [8/9] flink git commit: [hotfix] [tests] Simplify JobMasterTest - posted by tr...@apache.org on 2018/02/18 09:14:01 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-8546] [flip6] Respect savepoints and restore from latest checkpoints - posted by tr...@apache.org on 2018/02/18 09:14:02 UTC, 0 replies.
- flink git commit: [FLINK-8693][py] Remove redundant Intepreter initialization - posted by ch...@apache.org on 2018/02/18 20:51:05 UTC, 0 replies.
- flink git commit: [FLINK-8692][docs] Remove extra parenthesis in scala code samples - posted by ch...@apache.org on 2018/02/18 20:55:30 UTC, 1 replies.
- [1/8] flink git commit: [hotfix] [core] Remove Java 8 related reflection from TypeExtractionUtils. - posted by se...@apache.org on 2018/02/18 23:22:58 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-8548] [examples] Add state machine example - posted by se...@apache.org on 2018/02/18 23:22:59 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-8549] [config] Move TimerServiceOptions into TaskManagerOptions - posted by se...@apache.org on 2018/02/18 23:23:00 UTC, 0 replies.
- [4/8] flink git commit: [hotfix] [shell scripts] Use SSH-less fast path for both 'localhost' and '127.0.0.1' - posted by se...@apache.org on 2018/02/18 23:23:01 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-8681] [build] Remove 'planVisualizer.html' has moved notice - posted by se...@apache.org on 2018/02/18 23:23:02 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8680] [data stream api] Assign meaningful names to the sinks that print to std. out and std. err. - posted by se...@apache.org on 2018/02/18 23:23:03 UTC, 0 replies.
- [7/8] flink git commit: [hotfix] [core] Add old checkpoint directory config key back for compatibility. - posted by se...@apache.org on 2018/02/18 23:23:04 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-8682] [shell scripts] Make shell scripts work without SSH for local-only HA setups. - posted by se...@apache.org on 2018/02/18 23:23:05 UTC, 0 replies.
- flink git commit: [FLINK-8668] Remove "hadoop classpath" from config.sh - posted by al...@apache.org on 2018/02/19 09:32:30 UTC, 0 replies.
- [flink-shaded] branch master updated: (#31) Hard-code jackson-parent version - posted by ch...@apache.org on 2018/02/19 11:00:46 UTC, 0 replies.
- [flink-shaded] branch master updated: (#35) Bump netty to 4.0.56 - posted by ch...@apache.org on 2018/02/19 11:01:27 UTC, 0 replies.
- [flink-shaded] branch release-3.0 created (now 1233f1b) - posted by ch...@apache.org on 2018/02/19 11:12:51 UTC, 0 replies.
- [flink-shaded] branch master updated: Increment version to 4.0 - posted by ch...@apache.org on 2018/02/19 11:15:18 UTC, 0 replies.
- [flink-shaded] branch release-3.0-rc1 created (now 1233f1b) - posted by ch...@apache.org on 2018/02/19 11:29:34 UTC, 0 replies.
- [flink-shaded] branch master updated: (#37) Include jackson-dataformat-yaml and snakeyaml - posted by ch...@apache.org on 2018/02/19 12:54:31 UTC, 0 replies.
- [flink-shaded] branch release-3.0 updated: (#37) Include jackson-dataformat-yaml and snakeyaml - posted by ch...@apache.org on 2018/02/19 12:54:49 UTC, 0 replies.
- [flink-shaded] branch release-3.0 updated: (#38) Include missing javax validation-api dependency - posted by ch...@apache.org on 2018/02/19 13:03:11 UTC, 0 replies.
- [flink-shaded] branch master updated: (#38) Include missing javax validation-api dependency - posted by ch...@apache.org on 2018/02/19 13:03:26 UTC, 0 replies.
- [flink-shaded] branch release-3.0-rc2 created (now fd0f8cc) - posted by ch...@apache.org on 2018/02/19 13:04:13 UTC, 0 replies.
- [flink-shaded] tag 3.0-rc2 created (now fd0f8cc) - posted by ch...@apache.org on 2018/02/19 13:04:58 UTC, 0 replies.
- [01/35] flink git commit: [hotfix][network] Invert if check in SpanningRecordSerializer to improve readability - posted by sr...@apache.org on 2018/02/19 14:07:54 UTC, 0 replies.
- [02/35] flink git commit: [hotfix][tests] Do not hide original exception in Serialization tests - posted by sr...@apache.org on 2018/02/19 14:07:55 UTC, 0 replies.
- [03/35] flink git commit: [hotfix][runtime] Drop one of the two clear methods in RecordSerializer - posted by sr...@apache.org on 2018/02/19 14:07:56 UTC, 0 replies.
- [04/35] flink git commit: [hotfix][tests] Deduplicate code in LargeRecordsTest - posted by sr...@apache.org on 2018/02/19 14:07:57 UTC, 0 replies.
- [05/35] flink git commit: [hotfix][test] Deduplicate code in LargeRecordsTest and SpanningRecordSerializationTest - posted by sr...@apache.org on 2018/02/19 14:07:58 UTC, 0 replies.
- [06/35] flink git commit: [FLINK-8582][runtime] Introduce BufferConsumer - posted by sr...@apache.org on 2018/02/19 14:07:59 UTC, 0 replies.
- [07/35] flink git commit: [hotfix][test] Simplify RecordWriterTest - posted by sr...@apache.org on 2018/02/19 14:08:00 UTC, 0 replies.
- [08/35] flink git commit: [hotfix][runtime] Refactor ResultPartition for cleaner recycle path - posted by sr...@apache.org on 2018/02/19 14:08:01 UTC, 0 replies.
- [09/35] flink git commit: [hotfix][runtime] Fix recycleBuffer in ResultPartitionTest - posted by sr...@apache.org on 2018/02/19 14:08:02 UTC, 0 replies.
- [10/35] flink git commit: [hotfix][runtime] Deduplicate code in PipelinedSubpartition - posted by sr...@apache.org on 2018/02/19 14:08:03 UTC, 0 replies.
- [11/35] flink git commit: [hotfix][runtime] Deduplicate buffersInBacklog code in Pipelined and Spillable subtartitions - posted by sr...@apache.org on 2018/02/19 14:08:04 UTC, 0 replies.
- [12/35] flink git commit: [hotfix][runtime-tests] Immediatelly fail test when one of the futures fails - posted by sr...@apache.org on 2018/02/19 14:08:05 UTC, 0 replies.
- [13/35] flink git commit: [hotfix][runtime-tests] Deduplicate CollectingResultPartitionWriters classes - posted by sr...@apache.org on 2018/02/19 14:08:06 UTC, 0 replies.
- [14/35] flink git commit: [hotfix][tests] Reduce mockito usage in StreamTaskTest - posted by sr...@apache.org on 2018/02/19 14:08:07 UTC, 0 replies.
- [15/35] flink git commit: [FLINK-8590][runtime] Drop addBufferConsumerToAllSubpartitions method - posted by sr...@apache.org on 2018/02/19 14:08:08 UTC, 0 replies.
- [16/35] flink git commit: [FLINK-8584] handle read-only buffers in deserializer - posted by sr...@apache.org on 2018/02/19 14:08:09 UTC, 0 replies.
- [17/35] flink git commit: [FLINK-8583] Pass BufferConsumer to subpartitions - posted by sr...@apache.org on 2018/02/19 14:08:10 UTC, 0 replies.
- [18/35] flink git commit: [FLINK-8583] Pass BufferConsumer to subpartitions - posted by sr...@apache.org on 2018/02/19 14:08:11 UTC, 0 replies.
- [19/35] flink git commit: [hotfix][runtime] Simplify RecordWriter code - posted by sr...@apache.org on 2018/02/19 14:08:12 UTC, 0 replies.
- [20/35] flink git commit: [hotfix][java-docs] Improve ResultSubpartition java doc - posted by sr...@apache.org on 2018/02/19 14:08:13 UTC, 0 replies.
- [21/35] flink git commit: [hotfix][runtime] Simplify PipelinedSubpartition - posted by sr...@apache.org on 2018/02/19 14:08:14 UTC, 0 replies.
- [22/35] flink git commit: [hotfix][runtime] Drop unused throws IOException - posted by sr...@apache.org on 2018/02/19 14:08:15 UTC, 0 replies.
- [23/35] flink git commit: [FLINK-8586][tests] Clean up hard to maintain tests - posted by sr...@apache.org on 2018/02/19 14:08:16 UTC, 0 replies.
- [24/35] flink git commit: [hotfix][tests] Properly close StreamRecordWriter in network benchmarks - posted by sr...@apache.org on 2018/02/19 14:08:17 UTC, 0 replies.
- [25/35] flink git commit: [hotfix][tests] Correctly set moreAvailable flag in StreamTestSingleInputGate and handle redundant data notifications - posted by sr...@apache.org on 2018/02/19 14:08:18 UTC, 0 replies.
- [26/35] flink git commit: [FLINK-8587][runtime] Drop unused AdaptiveSpanningRecordDeserializer - posted by sr...@apache.org on 2018/02/19 14:08:19 UTC, 0 replies.
- [27/35] flink git commit: [FLINK-8588][runtime] Handle sliced buffers in RecordDeserializer - posted by sr...@apache.org on 2018/02/19 14:08:20 UTC, 0 replies.
- [28/35] flink git commit: [FLINK-8589][runtime] Add polling method to InputGate - posted by sr...@apache.org on 2018/02/19 14:08:21 UTC, 0 replies.
- [29/35] flink git commit: [FLINK-8591][runtime] Pass unfinished bufferConsumers to subpartitions - posted by sr...@apache.org on 2018/02/19 14:08:22 UTC, 0 replies.
- [30/35] flink git commit: [FLINK-8591][runtime] Pass unfinished bufferConsumers to subpartitions - posted by sr...@apache.org on 2018/02/19 14:08:23 UTC, 0 replies.
- [31/35] flink git commit: [hotfix][benchmarks] Add network stack benchmarks for LocalInputChannels - posted by sr...@apache.org on 2018/02/19 14:08:24 UTC, 0 replies.
- [32/35] flink git commit: [hotfix][tests] Properly clean up RescalingITCase and allow it to run in the loop - posted by sr...@apache.org on 2018/02/19 14:08:25 UTC, 0 replies.
- [33/35] flink git commit: [hotfix][tests] Remove masking original exception in StreamTaskTimerTest - posted by sr...@apache.org on 2018/02/19 14:08:26 UTC, 0 replies.
- [34/35] flink git commit: [FLINK-8582][runtime] Optimize BufferBuilder writes - posted by sr...@apache.org on 2018/02/19 14:08:27 UTC, 0 replies.
- [35/35] flink git commit: [hotfix][runtime] Rename setNextBufferBuilder to continueWritingWithNextBufferBuilder - posted by sr...@apache.org on 2018/02/19 14:08:28 UTC, 0 replies.
- flink git commit: [FLINK-8657][documentation] Fix incorrect description for configuration of async snapshot for heap based backend - posted by sr...@apache.org on 2018/02/19 14:31:58 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-8675] Add non-blocking shut down method to RestServerEndpoint - posted by tr...@apache.org on 2018/02/19 17:08:24 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8669] Add completeAll and runAfterwards(Async) to FutureUtils - posted by tr...@apache.org on 2018/02/19 17:08:25 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-7715][flip6] Implement JarRunHandler - posted by tr...@apache.org on 2018/02/19 17:08:26 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-7715][flip6] Implement JarRunHandler - posted by tr...@apache.org on 2018/02/19 17:08:27 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-7715][flip6] Implement JarRunHandler - posted by tr...@apache.org on 2018/02/19 17:08:28 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-7715][flip6] Implement JarRunHandler - posted by tr...@apache.org on 2018/02/19 17:08:29 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Remove unused code in JarActionHandler - posted by tr...@apache.org on 2018/02/19 17:08:30 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-7715] [flip6] Introduce WebSubmissionExtension for web submission handlers - posted by tr...@apache.org on 2018/02/19 17:08:31 UTC, 0 replies.
- [9/9] flink git commit: [hotfix] Harden SlotPoolRcpTest#testCancelSlotAllocationWithoutResourceManager - posted by tr...@apache.org on 2018/02/19 17:08:32 UTC, 0 replies.
- [1/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:37 UTC, 0 replies.
- [2/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:38 UTC, 0 replies.
- [3/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:39 UTC, 0 replies.
- [4/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:40 UTC, 0 replies.
- [5/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:41 UTC, 0 replies.
- [6/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:42 UTC, 0 replies.
- [7/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:43 UTC, 0 replies.
- [8/8] flink git commit: [FLINK-8695] [rocksdb] Move flink-statebackend-rocksdb from 'flink-contrib' to 'flink-state-backends'. - posted by se...@apache.org on 2018/02/19 17:39:44 UTC, 0 replies.
- flink git commit: [FLINK-8600] Allow disabling truncate() check in BucketingSink - posted by al...@apache.org on 2018/02/20 08:33:37 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8698] [flip6] Use Flip6LocalStreamEnvironment instead of LocalStreamEnvironment - posted by tr...@apache.org on 2018/02/20 10:17:10 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8698] [flip6] Let LocalExecutor use Flip-6 MiniCluster - posted by tr...@apache.org on 2018/02/20 10:17:11 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8709] [tests] Harden SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager - posted by tr...@apache.org on 2018/02/20 10:17:12 UTC, 0 replies.
- flink-web git commit: Update PMC status of Chesnay - posted by ch...@apache.org on 2018/02/20 15:40:44 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8574][travis] Add timestamp to logging messages - posted by ch...@apache.org on 2018/02/20 15:46:49 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8621][prometheus][tests] Remove endpointIsUnavailableAfterReporterIsClosed() - posted by ch...@apache.org on 2018/02/20 15:46:50 UTC, 0 replies.
- [3/4] flink git commit: [hotfix][prometheus] Document internal usage of CollectorRegistry.defaultRegistry - posted by ch...@apache.org on 2018/02/20 15:46:51 UTC, 0 replies.
- [4/4] flink git commit: [hotfix][prometheus][tests] Add utility for generating port ranges - posted by ch...@apache.org on 2018/02/20 15:46:52 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8621][prometheus][tests] Remove endpointIsUnavailableAfterReporterIsClosed() - posted by ch...@apache.org on 2018/02/20 15:48:49 UTC, 0 replies.
- [2/4] flink git commit: [hotfix][prometheus] Document internal usage of CollectorRegistry.defaultRegistry - posted by ch...@apache.org on 2018/02/20 15:48:50 UTC, 0 replies.
- [3/4] flink git commit: [hotfix][prometheus][tests] Add utility for generating port ranges - posted by ch...@apache.org on 2018/02/20 15:48:51 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8574][travis] Add timestamp to logging messages - posted by ch...@apache.org on 2018/02/20 15:48:52 UTC, 0 replies.
- flink git commit: [hotfix][docs] Update configuration docs - posted by ch...@apache.org on 2018/02/20 16:31:08 UTC, 0 replies.
- flink git commit: [FLINK-8709] [tests] Harden SlotPoolRpcTest.testCancelSlotAllocationWithoutResourceManager #2 - posted by tr...@apache.org on 2018/02/21 10:08:45 UTC, 0 replies.
- flink git commit: [FLINK-8668] Document how to set HADOOP_CLASSPATH for Flink - posted by al...@apache.org on 2018/02/21 11:19:31 UTC, 0 replies.
- flink git commit: [FLINK-8723] Remove existing broadcast state examples. - posted by kk...@apache.org on 2018/02/21 14:10:53 UTC, 0 replies.
- [1/5] flink git commit: [hotfix] Fix various typos - posted by ch...@apache.org on 2018/02/21 17:20:02 UTC, 0 replies.
- [2/5] flink git commit: [hotfix][table][tests] Set @Ignore description for RowCsvInputFormatTest#testParserCorrectness - posted by ch...@apache.org on 2018/02/21 17:20:03 UTC, 0 replies.
- [3/5] flink git commit: [FLINK-8703][tests] Migrate tests to MiniClusterResource (batch #1) - posted by ch...@apache.org on 2018/02/21 17:20:04 UTC, 0 replies.
- [4/5] flink git commit: [hotfix][build] Set flink-shaded-jackson to provided - posted by ch...@apache.org on 2018/02/21 17:20:05 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8713][tests] Ensure outdated mod time is smaller than minimum - posted by ch...@apache.org on 2018/02/21 17:20:06 UTC, 0 replies.
- [1/7] flink git commit: [FLINK-8738] [build] Converge dependency versions for 'scala-lang' and for 'com.typesafe:config' - posted by se...@apache.org on 2018/02/21 21:09:11 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-8696] [shell scripts] Remove JobManager local mode from shell scripts - posted by se...@apache.org on 2018/02/21 21:09:12 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-6489] [shell scripts] Remove local mode from Windows start-local.bat - posted by se...@apache.org on 2018/02/21 21:09:13 UTC, 0 replies.
- [4/7] flink git commit: [hotfix] [shell scripts] Remove hostname from Windows log and out files - posted by se...@apache.org on 2018/02/21 21:09:14 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-6489] [FLINK-8696] [docs] Update docs to use 'start-cluster.sh' instead of 'start-local.sh' - posted by se...@apache.org on 2018/02/21 21:09:15 UTC, 0 replies.
- [6/7] flink git commit: [hotfix] [tests] Update port of Travis end-to-end tests to match temporary Flip-6 web UI port - posted by se...@apache.org on 2018/02/21 21:09:16 UTC, 0 replies.
- [7/7] flink git commit: [hotfix] [tests] Decrease verbosity of ent-to-end test cluster start checks - posted by se...@apache.org on 2018/02/21 21:09:17 UTC, 0 replies.
- [01/13] flink git commit: [FLINK-8705] [flip6] Add Flip-6 support to Remote(Stream)Environment - posted by tr...@apache.org on 2018/02/21 22:56:20 UTC, 0 replies.
- [02/13] flink git commit: [FLINK-8710] [YARN] AbstractYarnClusterDescriptor doesn't use pre-defined configs in Hadoop's YarnConfiguration - posted by tr...@apache.org on 2018/02/21 22:56:21 UTC, 0 replies.
- [03/13] flink git commit: [FLINK-8705] [flip6] Add DispatcherRestEndpoint to MiniCluster - posted by tr...@apache.org on 2018/02/21 22:56:22 UTC, 0 replies.
- [04/13] flink git commit: [FLINK-7712][flip6] Implement JarDeleteHandler - posted by tr...@apache.org on 2018/02/21 22:56:23 UTC, 0 replies.
- [05/13] flink git commit: [hotfix] Rename JarUploadMessageHeaders to JarUploadHeaders - posted by tr...@apache.org on 2018/02/21 22:56:24 UTC, 0 replies.
- [06/13] flink git commit: [FLINK-7714][flip6] Implement JarPlanHandler - posted by tr...@apache.org on 2018/02/21 22:56:25 UTC, 0 replies.
- [07/13] flink git commit: [FLINK-7714][flip6] Implement JarPlanHandler - posted by tr...@apache.org on 2018/02/21 22:56:26 UTC, 0 replies.
- [08/13] flink git commit: [FLINK-7714][flip6] Implement JarPlanHandler - posted by tr...@apache.org on 2018/02/21 22:56:27 UTC, 0 replies.
- [09/13] flink git commit: [hotfix] Move JarListInfoTest to correct package - posted by tr...@apache.org on 2018/02/21 22:56:28 UTC, 0 replies.
- [10/13] flink git commit: [FLINK-8711] [yarn] Remove code which auto-magically changes slots per TM - posted by tr...@apache.org on 2018/02/21 22:56:29 UTC, 0 replies.
- [11/13] flink git commit: [FLINK-8631] [rest] Add support for generic types to the RestClient - posted by tr...@apache.org on 2018/02/21 22:56:30 UTC, 0 replies.
- [12/13] flink git commit: [FLINK-8632] [flip6] Introduce generalized asynchronous operation handlers - posted by tr...@apache.org on 2018/02/21 22:56:31 UTC, 0 replies.
- [13/13] flink git commit: [FLINK-8632] [flip6] Introduce generalized asynchronous operation handlers - posted by tr...@apache.org on 2018/02/21 22:56:32 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8547][network] Implement CheckpointBarrierHandler not to spill data for exactly-once - posted by sr...@apache.org on 2018/02/22 13:29:24 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8547][network] Implement CheckpointBarrierHandler not to spill data for exactly-once - posted by sr...@apache.org on 2018/02/22 13:29:25 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8547][network] Implement CheckpointBarrierHandler not to spill data for exactly-once - posted by sr...@apache.org on 2018/02/22 13:29:26 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8547][network] Implement CheckpointBarrierHandler not to spill data for exactly-once - posted by sr...@apache.org on 2018/02/22 13:29:27 UTC, 0 replies.
- flink git commit: [FLINK-8674][runtime] Improve performance of flushAlways in StreamRecordWriter - posted by sr...@apache.org on 2018/02/22 14:17:15 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8735] Add new StatefulJobSavepointMigrationITCase - posted by al...@apache.org on 2018/02/22 14:30:49 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8735] Rename StatefulJobSavepointMigrationITCase - posted by al...@apache.org on 2018/02/22 14:30:50 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8735] Rename StatefulJobSavepointMigrationITCase - posted by al...@apache.org on 2018/02/22 14:38:56 UTC, 0 replies.
- [2/2] flink git commit: [FLINK-8735] Add new StatefulJobSavepointMigrationITCase - posted by al...@apache.org on 2018/02/22 14:38:57 UTC, 0 replies.
- flink git commit: [FLINK-8639][State Backends] Fix always need to seek multiple times when iterator RocksDBMapState - posted by sr...@apache.org on 2018/02/22 14:59:04 UTC, 0 replies.
- flink git commit: [FLINK-8732] [flip6] Cancel ongoing scheduling operation - posted by tr...@apache.org on 2018/02/22 16:22:21 UTC, 0 replies.
- [1/7] flink git commit: [hotfix] Fix checkstyle violations in ExecutionGraph - posted by tr...@apache.org on 2018/02/23 09:24:32 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-8633] [flip6] Expose rescaling of jobs via the Dispatcher - posted by tr...@apache.org on 2018/02/23 09:24:33 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8627] Introduce new JobStatus#SUSPENDING to ExecutionGraph - posted by tr...@apache.org on 2018/02/23 09:24:34 UTC, 0 replies.
- [4/7] flink git commit: [FLINK-8629] [flip6] Allow JobMaster to rescale jobs - posted by tr...@apache.org on 2018/02/23 09:24:35 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-8634] [rest] Introduce job rescaling REST handler - posted by tr...@apache.org on 2018/02/23 09:24:36 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-8635] [rest] Register rescaling handlers at web endpoint - posted by tr...@apache.org on 2018/02/23 09:24:37 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-8656] [flip6] Add modify CLI command to rescale Flink jobs - posted by tr...@apache.org on 2018/02/23 09:24:38 UTC, 0 replies.
- flink git commit: [FLINK-8679][State Backends] Ensure that RocksDBKeyedBackend.getKeys() filters keys by namespace - posted by sr...@apache.org on 2018/02/23 09:58:40 UTC, 0 replies.
- flink git commit: [FLINK-8648] [kinesis] Allow for customization of emitRecordAndUpdateState in Kinesis connector. - posted by tz...@apache.org on 2018/02/23 11:48:54 UTC, 0 replies.
- flink git commit: [FLINK-8754][flip6] Make TaskManagerInfo implement Serializable - posted by tr...@apache.org on 2018/02/23 13:12:28 UTC, 0 replies.
- flink git commit: [hotfix] [formats] Dependency and code clean-up - posted by tw...@apache.org on 2018/02/23 14:13:07 UTC, 0 replies.
- flink git commit: [hotfix] [sql-client] Use hard-coded Scala version - posted by tw...@apache.org on 2018/02/23 14:18:39 UTC, 0 replies.
- flink-web git commit: [hotfix] Update quickstarts to Flink 1.4.1 - posted by tw...@apache.org on 2018/02/23 16:28:09 UTC, 0 replies.
- flink git commit: [hotfix] Update docs version to Flink 1.4.1 - posted by tw...@apache.org on 2018/02/23 16:32:38 UTC, 0 replies.
- [01/10] flink git commit: [FLINK-8664] [rest] Change RpcEndpoint#TerminationFuture value type to Void - posted by tr...@apache.org on 2018/02/24 11:32:40 UTC, 0 replies.
- [02/10] flink git commit: [FLINK-8678] [flip6] Make RpcService shut down non blocking - posted by tr...@apache.org on 2018/02/24 11:32:41 UTC, 0 replies.
- [03/10] flink git commit: [hotfix] Don't fail LeaderContender and Listener when closing EmbeddedLeaderService - posted by tr...@apache.org on 2018/02/24 11:32:42 UTC, 0 replies.
- [04/10] flink git commit: [hotfix] Fix checkstyle violations in RpcEndpoint - posted by tr...@apache.org on 2018/02/24 11:32:43 UTC, 0 replies.
- [05/10] flink git commit: [hotfix] Remove unused method MiniCluster#waitUntilTaskManagerRegistrationsComplete - posted by tr...@apache.org on 2018/02/24 11:32:44 UTC, 0 replies.
- [06/10] flink git commit: [FLINK-8665] [rest] Let RpcEndpoint#postStop return completion future - posted by tr...@apache.org on 2018/02/24 11:32:45 UTC, 0 replies.
- [07/10] flink git commit: [FLINK-8670] Make MetricRegistryImpl#shutdown non blocking - posted by tr...@apache.org on 2018/02/24 11:32:46 UTC, 0 replies.
- [08/10] flink git commit: [FLINK-8666] [test] Use testDispatcherConfig in MiniCluster - posted by tr...@apache.org on 2018/02/24 11:32:47 UTC, 0 replies.
- [09/10] flink git commit: [FLINK-8677] [flip6] Make ClusterEntrypoint shut down non-blocking - posted by tr...@apache.org on 2018/02/24 11:32:48 UTC, 0 replies.
- [10/10] flink git commit: [hotfix] Workaround for shut down deadlock of Netty < 4.0.33 - posted by tr...@apache.org on 2018/02/24 11:32:49 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-8138] [tests] Fix TaskAsyncCallTest#testSetsUserCodeClassLoader - posted by tr...@apache.org on 2018/02/24 18:17:43 UTC, 0 replies.
- [2/9] flink git commit: [hotfix] Register job status listener for rescaled job - posted by tr...@apache.org on 2018/02/24 18:17:44 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-8746] [flip6] Allow rescaling of partially running jobs - posted by tr...@apache.org on 2018/02/24 18:17:45 UTC, 0 replies.
- [4/9] flink git commit: [hotfix] Don't use tmp directory for rescaling savepoints - posted by tr...@apache.org on 2018/02/24 18:17:46 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-8748] [flip6] Cancel slot allocations for alternatively completed slot requests - posted by tr...@apache.org on 2018/02/24 18:17:47 UTC, 0 replies.
- [6/9] flink git commit: [hotfix] Avoid redundant slot release operations - posted by tr...@apache.org on 2018/02/24 18:17:48 UTC, 0 replies.
- [7/9] flink git commit: [hotfix] Cancel pending slot request when SlotPool is suspended - posted by tr...@apache.org on 2018/02/24 18:17:49 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-8749] [flip6] Release slots when scheduling operation is canceled - posted by tr...@apache.org on 2018/02/24 18:17:50 UTC, 0 replies.
- [9/9] flink git commit: [hotfix] Improve code structure of JobMaster#rescaleOperators - posted by tr...@apache.org on 2018/02/24 18:17:51 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8773] [flip6] Make JobManagerRunner shut down non blocking - posted by tr...@apache.org on 2018/02/25 08:49:07 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8774] [flip6] Make shut down of ResourceManagerRunner non blocking - posted by tr...@apache.org on 2018/02/25 08:49:08 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8775] [flip6] Non blocking MiniCluster shut down - posted by tr...@apache.org on 2018/02/25 08:49:09 UTC, 0 replies.
- [01/26] flink git commit: [hotfix] Rename OperatorSnapshotResult to OperatorSnapshotFutures. - posted by sr...@apache.org on 2018/02/25 16:11:35 UTC, 0 replies.
- [02/26] flink git commit: [hotfix] Remove outdated class OperatorStateHandles and replace it with OperatorSubtaskState - posted by sr...@apache.org on 2018/02/25 16:11:36 UTC, 0 replies.
- [03/26] flink git commit: [hotfix] Remove outdated class OperatorStateHandles and replace it with OperatorSubtaskState - posted by sr...@apache.org on 2018/02/25 16:11:37 UTC, 0 replies.
- [04/26] flink git commit: [hotfix] Do not track completed checkpoint ids without incremental checkpointing - posted by sr...@apache.org on 2018/02/25 16:11:38 UTC, 0 replies.
- [05/26] flink git commit: [hotfix] Remove some unecessary null checks in RocksDBKeyedStateBackend - posted by sr...@apache.org on 2018/02/25 16:11:39 UTC, 0 replies.
- [06/26] flink git commit: [hotfix] Introduce ShutdownHookUtil to avoid code duplication - posted by sr...@apache.org on 2018/02/25 16:11:40 UTC, 0 replies.
- [07/26] flink git commit: [FLINK-8360][checkpointing] Implement file-based local recovery for FsStateBackend - posted by sr...@apache.org on 2018/02/25 16:11:41 UTC, 0 replies.
- [08/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:42 UTC, 0 replies.
- [09/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:43 UTC, 0 replies.
- [10/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:44 UTC, 0 replies.
- [11/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:45 UTC, 0 replies.
- [12/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:46 UTC, 0 replies.
- [13/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:47 UTC, 0 replies.
- [14/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:48 UTC, 0 replies.
- [15/26] flink git commit: [FLINK-8360][checkpointing] Implement state storage for local recovery and integrate with task lifecycle - posted by sr...@apache.org on 2018/02/25 16:11:49 UTC, 0 replies.
- [16/26] flink git commit: [hotfix] Suppress emitting non-causal exceptions from closed checkpointing thread - posted by sr...@apache.org on 2018/02/25 16:11:50 UTC, 0 replies.
- [17/26] flink git commit: [FLINK-8699][checkpointing] Create deep copy of state meta data to avoid concurrency problem with checkpoints - posted by sr...@apache.org on 2018/02/25 16:11:51 UTC, 0 replies.
- [18/26] flink git commit: [hotfix] RocksDB make default column family first - posted by sr...@apache.org on 2018/02/25 16:11:52 UTC, 0 replies.
- [19/26] flink git commit: [FLINK-8360][checkpointing] Documentation for local recovery - posted by sr...@apache.org on 2018/02/25 16:11:53 UTC, 0 replies.
- [20/26] flink git commit: [FLINK-8360][checkpointing] Implement file-based local recovery for RocksDBStateBackend - posted by sr...@apache.org on 2018/02/25 16:11:54 UTC, 0 replies.
- [21/26] flink git commit: [FLINK-8360][checkpointing] Implement file-based local recovery for RocksDBStateBackend - posted by sr...@apache.org on 2018/02/25 16:11:55 UTC, 0 replies.
- [22/26] flink git commit: [FLINK-8360][checkpointing] Implement file-based local recovery for RocksDBStateBackend - posted by sr...@apache.org on 2018/02/25 16:11:56 UTC, 0 replies.
- [23/26] flink git commit: [hotfix] Replace use of deprecated remove calls to RocksDB with delete - posted by sr...@apache.org on 2018/02/25 16:11:57 UTC, 0 replies.
- [24/26] flink git commit: [hotfix] Update RocksDB version to 5.7.5 - posted by sr...@apache.org on 2018/02/25 16:11:58 UTC, 0 replies.
- [25/26] flink git commit: [hotfix] RocksDB improve resource cleanup (disposal order, dispose all WriteOptions) - posted by sr...@apache.org on 2018/02/25 16:11:59 UTC, 0 replies.
- [26/26] flink git commit: [hotfix] Clear interrupted flag in stream task cancellation - posted by sr...@apache.org on 2018/02/25 16:12:00 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8776][flip6] Use correct port for job submission from Web UI. - posted by tr...@apache.org on 2018/02/26 10:10:05 UTC, 0 replies.
- [2/2] flink git commit: [hotfix] Initialize webSubmissionHandlers list in WebSubmissionExtension with correct size. - posted by tr...@apache.org on 2018/02/26 10:10:06 UTC, 0 replies.
- [1/9] flink git commit: [hotfix] [quickstarts] Fix header and package declaration order. - posted by se...@apache.org on 2018/02/26 12:03:30 UTC, 0 replies.
- [2/9] flink git commit: [FLINK-8762] [quickstarts] Make 'StreamingJob' the default main class and remove WordCount example from the quickstart. - posted by se...@apache.org on 2018/02/26 12:03:31 UTC, 0 replies.
- [3/9] flink git commit: [FLINK-8766] [quickstarts] Pin scala runtime version for Java Quickstart - posted by se...@apache.org on 2018/02/26 12:03:32 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-8763] [quickstarts] Remove obsolete Dummy.java classes from quickstart projects. - posted by se...@apache.org on 2018/02/26 12:03:33 UTC, 0 replies.
- [5/9] flink git commit: [hotfix] [quickstarts] Fix block comments in program stubs. - posted by se...@apache.org on 2018/02/26 12:03:34 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-8764] [quickstarts] Make quickstarts work out of the box for IDE and JAR packaging - posted by se...@apache.org on 2018/02/26 12:03:35 UTC, 0 replies.
- [7/9] flink git commit: [FLINK-8767] [quickstarts] Set the maven.compiler.source and .target properties for Java Quickstart - posted by se...@apache.org on 2018/02/26 12:03:36 UTC, 1 replies.
- [8/9] flink git commit: [FLINK-8765] [quickstarts] Simplify quickstart properties - posted by se...@apache.org on 2018/02/26 12:03:37 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-8764] [docs] Adjust quickstart documentation - posted by se...@apache.org on 2018/02/26 12:03:38 UTC, 0 replies.
- [1/3] flink git commit: [FLINK-8781][scheduler] Try to reschedule failed tasks to previous allocation - posted by sr...@apache.org on 2018/02/26 14:32:18 UTC, 0 replies.
- [2/3] flink git commit: [FLINK-8781][scheduler] Try to reschedule failed tasks to previous allocation - posted by sr...@apache.org on 2018/02/26 14:32:19 UTC, 0 replies.
- [3/3] flink git commit: [FLINK-8781][scheduler] Try to reschedule failed tasks to previous allocation - posted by sr...@apache.org on 2018/02/26 14:32:20 UTC, 0 replies.
- [1/4] flink git commit: [hotfix] [test] Also trap INT signal in Kafka end-to-end test - posted by tz...@apache.org on 2018/02/26 15:16:06 UTC, 0 replies.
- [2/4] flink git commit: [hotfix] [test] Make test-streaming-kafka010.sh more flexible for local execution - posted by tz...@apache.org on 2018/02/26 15:16:07 UTC, 1 replies.
- [3/4] flink git commit: [FLINK-8741] [kafka] Fix incorrect user code classloader in FlinkKafkaConsumer - posted by tz...@apache.org on 2018/02/26 15:16:08 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8772] [kafka] Fix missing log parameter - posted by tz...@apache.org on 2018/02/26 15:16:09 UTC, 1 replies.
- [1/4] flink git commit: [FLINK-8741] [kafka] Fix incorrect user code classloader in FlinkKafkaConsumer - posted by tz...@apache.org on 2018/02/26 15:17:17 UTC, 0 replies.
- [3/4] flink git commit: [hotfix] [test] Also trap INT signal in Kafka end-to-end test - posted by tz...@apache.org on 2018/02/26 15:17:19 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8593][metrics] Update latency metric docs - posted by ch...@apache.org on 2018/02/26 19:43:37 UTC, 0 replies.
- [2/4] flink git commit: [FLINK-8596][CLI] Also catch NoClassDefFoundErrors - posted by ch...@apache.org on 2018/02/26 19:43:38 UTC, 0 replies.
- [3/4] flink git commit: [FLINK-8645][configuration] Split classloader.parent-first-patterns into "base" and "append - posted by ch...@apache.org on 2018/02/26 19:43:39 UTC, 0 replies.
- [4/4] flink git commit: [FLINK-8703][tests] Migrate tests to MiniClusterResource (batch #2) - posted by ch...@apache.org on 2018/02/26 19:43:40 UTC, 0 replies.
- flink git commit: [FLINK-8543] Don't call super.close() in AvroKeyValueSinkWriter - posted by al...@apache.org on 2018/02/26 20:11:21 UTC, 1 replies.
- svn commit: r25298 - /release/flink/KEYS - posted by tr...@apache.org on 2018/02/27 07:53:13 UTC, 0 replies.
- [1/6] flink git commit: [FLINK-8734][network] fix partition bytes counting and re-enable in tests - posted by tr...@apache.org on 2018/02/27 08:22:18 UTC, 0 replies.
- [2/6] flink git commit: [FLINK-8733][network] fix SpillableSubpartition#spillFinishedBufferConsumers() not counting spilled bytes - posted by tr...@apache.org on 2018/02/27 08:22:19 UTC, 0 replies.
- [3/6] flink git commit: [hotfix][network] various minor improvements - posted by tr...@apache.org on 2018/02/27 08:22:20 UTC, 0 replies.
- [4/6] flink git commit: [hotfix][network] remove PowerMockRunner from RecordWriterTest - posted by tr...@apache.org on 2018/02/27 08:22:21 UTC, 0 replies.
- [5/6] flink git commit: [hotfix][network] initialize SingleInputGate#enqueuedInputChannelsWithData with the right size - posted by tr...@apache.org on 2018/02/27 08:22:22 UTC, 0 replies.
- [6/6] flink git commit: [FLINK-8736][network] fix memory segment offsets for slices of slices being wrong - posted by tr...@apache.org on 2018/02/27 08:22:23 UTC, 0 replies.
- flink git commit: [FLINK-8719] Add module description for flink-contrib to clarify its purpose - posted by ch...@apache.org on 2018/02/27 09:20:49 UTC, 0 replies.
- flink git commit: [hotfix][tests] Remove unused variable - posted by ch...@apache.org on 2018/02/27 11:24:11 UTC, 0 replies.
- flink git commit: Update version to 1.6-SNAPSHOT - posted by tr...@apache.org on 2018/02/27 14:06:31 UTC, 0 replies.
- flink git commit: [hotfix] Improved logging for task local recovery - posted by sr...@apache.org on 2018/02/27 14:37:13 UTC, 1 replies.
- flink git commit: [FLINK-8798] [core] Force 'commons-logging' to be parent-first loaded. - posted by se...@apache.org on 2018/02/27 16:10:08 UTC, 0 replies.
- [1/2] flink git commit: [hotfix] [core] Suppress unused warning config options only used in shell scripts and doc generation. - posted by se...@apache.org on 2018/02/27 16:19:19 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8798] [core] Make force 'commons-logging' to be parent-first loaded. - posted by se...@apache.org on 2018/02/27 16:19:20 UTC, 1 replies.
- [1/5] flink git commit: [FLINK-8538][table]Add a Kafka table source factory with JSON format support - posted by tw...@apache.org on 2018/02/27 19:19:46 UTC, 0 replies.
- [2/5] flink git commit: [FLINK-8538] [table] Improve unified table sources - posted by tw...@apache.org on 2018/02/27 19:19:47 UTC, 1 replies.
- [3/5] flink git commit: [FLINK-8538] [table] Improve unified table sources - posted by tw...@apache.org on 2018/02/27 19:19:48 UTC, 1 replies.
- [4/5] flink git commit: [FLINK-8538] [table] Improve unified table sources - posted by tw...@apache.org on 2018/02/27 19:19:49 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-8538] [table] Improve unified table sources - posted by tw...@apache.org on 2018/02/27 19:19:50 UTC, 0 replies.
- [1/5] flink git commit: [FLINK-8538] [table] Improve unified table sources - posted by tw...@apache.org on 2018/02/27 19:25:16 UTC, 0 replies.
- [5/5] flink git commit: [FLINK-8538][table]Add a Kafka table source factory with JSON format support - posted by tw...@apache.org on 2018/02/27 19:25:20 UTC, 0 replies.
- [flink-shaded] tag 3.0 created (now fd0f8cc) - posted by ch...@apache.org on 2018/02/28 09:21:11 UTC, 0 replies.
- flink git commit: [FLINK-8791] [docs] Fix documentation about configuring dependencies - posted by se...@apache.org on 2018/02/28 10:25:54 UTC, 1 replies.
- svn commit: r25326 - in /release/flink/flink-shaded-3.0: ./ flink-shaded-3.0-src.tgz flink-shaded-3.0-src.tgz.asc flink-shaded-3.0-src.tgz.md5 flink-shaded-3.0-src.tgz.sha - posted by ch...@apache.org on 2018/02/28 10:34:11 UTC, 0 replies.
- [1/9] flink git commit: [FLINK-8762] [quickstarts] Make 'StreamingJob' the default main class and remove WordCount example from the quickstart. - posted by se...@apache.org on 2018/02/28 10:57:21 UTC, 0 replies.
- [2/9] flink git commit: [hotfix] [quickstarts] Fix header and package declaration order. - posted by se...@apache.org on 2018/02/28 10:57:22 UTC, 0 replies.
- [3/9] flink git commit: [hotfix] [quickstarts] Fix block comments in program stubs. - posted by se...@apache.org on 2018/02/28 10:57:23 UTC, 0 replies.
- [4/9] flink git commit: [FLINK-8764] [quickstarts] Make quickstarts work out of the box for IDE and JAR packaging - posted by se...@apache.org on 2018/02/28 10:57:24 UTC, 0 replies.
- [5/9] flink git commit: [FLINK-8765] [quickstarts] Simplify quickstart properties - posted by se...@apache.org on 2018/02/28 10:57:25 UTC, 0 replies.
- [6/9] flink git commit: [FLINK-8766] [quickstarts] Pin scala runtime version for Java Quickstart - posted by se...@apache.org on 2018/02/28 10:57:26 UTC, 0 replies.
- [8/9] flink git commit: [FLINK-8764] [docs] Adjust quickstart documentation - posted by se...@apache.org on 2018/02/28 10:57:28 UTC, 0 replies.
- [9/9] flink git commit: [FLINK-8791] [docs] Fix documentation about configuring dependencies - posted by se...@apache.org on 2018/02/28 10:57:29 UTC, 0 replies.
- [1/4] flink git commit: [FLINK-8730][REST] JSON serialize entire SerializedThrowable - posted by tr...@apache.org on 2018/02/28 12:27:32 UTC, 1 replies.
- [2/4] flink git commit: [FLINK-8787][flip6] Do not copy flinkConfiguration in AbstractYarnClusterDescriptor - posted by tr...@apache.org on 2018/02/28 12:27:33 UTC, 1 replies.
- [3/4] flink git commit: [FLINK-8792] [rest] Change MessageQueryParameter.convertStringToValue to convertValueToString - posted by tr...@apache.org on 2018/02/28 12:27:34 UTC, 1 replies.
- [4/4] flink git commit: [FLINK-8792] [rest] Change MessageQueryParameter#convertValueFromString to convertStringToValue - posted by tr...@apache.org on 2018/02/28 12:27:35 UTC, 1 replies.
- flink git commit: [FLINK-8451] [serializers] Make Scala tuple serializer deserialization more failure tolerant - posted by tw...@apache.org on 2018/02/28 12:29:55 UTC, 2 replies.
- flink git commit: [FLINK-8777][checkpointing] Cleanup local state more eagerly in recovery - posted by sr...@apache.org on 2018/02/28 12:34:54 UTC, 1 replies.
- [flink-shaded] branch master updated: (#39) Properly hide jackson dependencies - posted by ch...@apache.org on 2018/02/28 13:19:38 UTC, 0 replies.
- flink git commit: [hotfix] Enable FILESYTEM_DEFAULT_OVERRIDE in FLIP-6 MiniClusterResource - posted by al...@apache.org on 2018/02/28 14:38:26 UTC, 1 replies.
- flink git commit: [FLINK-8557][checkpointing] Remove illegal characters from operator description text before using it to construct the instance directory in RocksDB - posted by sr...@apache.org on 2018/02/28 14:48:18 UTC, 1 replies.
- [1/7] flink git commit: [FLINK-8805][runtime] Optimize EvenSerializer.isEvent method - posted by sr...@apache.org on 2018/02/28 16:15:56 UTC, 0 replies.
- [2/7] flink git commit: [FLINK-8694][runtime] Fix notifyDataAvailable race condition - posted by sr...@apache.org on 2018/02/28 16:15:57 UTC, 0 replies.
- [3/7] flink git commit: [hotfix][runtime] Remove duplicated check - posted by sr...@apache.org on 2018/02/28 16:15:58 UTC, 0 replies.
- [4/7] flink git commit: [hotfix][tests] Deduplicate code in SingleInputGateTest - posted by sr...@apache.org on 2018/02/28 16:15:59 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-8760][runtime] Correctly propagate moreAvailable flag through SingleInputGate - posted by sr...@apache.org on 2018/02/28 16:16:00 UTC, 0 replies.
- [6/7] flink git commit: [hotfix][tests] Do not hide original exception in SuccessAfterNetworkBuffersFailureITCase - posted by sr...@apache.org on 2018/02/28 16:16:01 UTC, 0 replies.
- [7/7] flink git commit: [FLINK-8750][runtime] Improve detection of no remaining data after EndOfPartitionEvent - posted by sr...@apache.org on 2018/02/28 16:16:02 UTC, 1 replies.
- [1/7] flink git commit: [hotfix][tests] Deduplicate code in SingleInputGateTest - posted by sr...@apache.org on 2018/02/28 16:17:47 UTC, 0 replies.
- [2/7] flink git commit: [hotfix][runtime] Remove duplicated check - posted by sr...@apache.org on 2018/02/28 16:17:48 UTC, 0 replies.
- [3/7] flink git commit: [FLINK-8760][runtime] Correctly propagate moreAvailable flag through SingleInputGate - posted by sr...@apache.org on 2018/02/28 16:17:49 UTC, 0 replies.
- [4/7] flink git commit: [hotfix][tests] Do not hide original exception in SuccessAfterNetworkBuffersFailureITCase - posted by sr...@apache.org on 2018/02/28 16:17:50 UTC, 0 replies.
- [5/7] flink git commit: [FLINK-8694][runtime] Fix notifyDataAvailable race condition - posted by sr...@apache.org on 2018/02/28 16:17:51 UTC, 0 replies.
- [6/7] flink git commit: [FLINK-8805][runtime] Optimize EvenSerializer.isEvent method - posted by sr...@apache.org on 2018/02/28 16:17:52 UTC, 0 replies.
- [1/2] flink git commit: [FLINK-8747][bugfix] The tag of waiting for floating buffers in RemoteInputChannel should be updated properly - posted by sr...@apache.org on 2018/02/28 16:23:30 UTC, 1 replies.
- [2/2] flink git commit: [hotfix] Fix package private and comments - posted by sr...@apache.org on 2018/02/28 16:23:31 UTC, 1 replies.
- [1/2] flink git commit: [hotfix][network] minor improvements in UnionInputGate - posted by sr...@apache.org on 2018/02/28 16:34:38 UTC, 1 replies.
- [2/2] flink git commit: [FLINK-8737][network] disallow creating a union of UnionInputGate instances - posted by sr...@apache.org on 2018/02/28 16:34:39 UTC, 1 replies.
- flink git commit: [hotfix] [tests] Fix SelfConnectionITCase - posted by se...@apache.org on 2018/02/28 16:53:15 UTC, 1 replies.
- [1/5] flink git commit: [hotfix] Add missing space to log message in ZooKeeperLeaderElectionService - posted by tr...@apache.org on 2018/02/28 22:02:40 UTC, 1 replies.
- [2/5] flink git commit: [hotfix][Javadoc] Fix typo in YarnTestBase: teh -> the - posted by tr...@apache.org on 2018/02/28 22:02:41 UTC, 1 replies.
- [3/5] flink git commit: [hotfix][Javadoc] Fix typo in YARN Utils: teh -> the - posted by tr...@apache.org on 2018/02/28 22:02:42 UTC, 1 replies.
- [4/5] flink git commit: [hotfix][tests] Fix wrong assertEquals in YARNSessionCapacitySchedulerITCase - posted by tr...@apache.org on 2018/02/28 22:02:43 UTC, 1 replies.
- [5/5] flink git commit: [FLINK-7805][flip6] Recover YARN containers after AM restart. - posted by tr...@apache.org on 2018/02/28 22:02:44 UTC, 1 replies.