Jenkins build is back to normal : flink-snapshot-deployment #206

See

buildbot failure in on flink-docs-release-0.9

The Buildbot has detected a new failure on builder flink-docs-release-0.9 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.9/builds/432 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

buildbot failure in on flink-docs-release-0.10

The Buildbot has detected a new failure on builder flink-docs-release-0.10 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-0.10/builds/317 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

buildbot failure in on flink-docs-release-1.1

The Buildbot has detected a new failure on builder flink-docs-release-1.1 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.1/builds/33 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave2_ubuntu Build Reason: The

[01/27] flink git commit: [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

Repository: flink Updated Branches: refs/heads/master 7cd9bb5f1 -> bdf9f86c5 http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-tests/src/test/java/org/apache/flink/test/streaming/api/StreamingOperatorsITCase.java

[06/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AggregatingAlignedProcessingTimeWindowOperatorTest.java -- diff --git

[20/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

[FLINK-4381] Refactor State to Prepare For Key-Group State Backends Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/847ead01 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/847ead01 Diff:

[13/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

[FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware The biggest change in this is that functionality that used to be in AbstractStateBackend is now moved to CheckpointStreamFactory and KeyedStateBackend. The former is responsible for providing streams that can be used to

[21/27] flink git commit: [FLINK-4380] Remove KeyGroupAssigner in favor of static method/Have default max. parallelism at 128

http://git-wip-us.apache.org/repos/asf/flink/blob/6d430618/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGeneratorTest.java -- diff --git

[05/27] flink git commit: [FLINK-3761] Refactor RocksDB Backend/Make Key-Group Aware

[FLINK-3761] Refactor RocksDB Backend/Make Key-Group Aware This change makes the RocksDB backend key-group aware by building on the changes in the previous commit. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/addd0842

[24/27] flink git commit: [FLINK-4380] Add tests for new Key-Group/Max-Parallelism

[FLINK-4380] Add tests for new Key-Group/Max-Parallelism This tests the rescaling features in CheckpointCoordinator and SavepointCoordinator. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/516ad011 Tree:

[22/27] flink git commit: [FLINK-4380] Remove KeyGroupAssigner in favor of static method/Have default max. parallelism at 128

[FLINK-4380] Remove KeyGroupAssigner in favor of static method/Have default max. parallelism at 128 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6d430618 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6d430618

[15/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

http://git-wip-us.apache.org/repos/asf/flink/blob/847ead01/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java -- diff --git

[14/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

http://git-wip-us.apache.org/repos/asf/flink/blob/847ead01/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java -- diff --git

[03/27] flink git commit: [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

[FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter This introduces a new KeySelector that assigns keys to key groups and also adds the max parallelism parameter throughout all API levels. This also adds tests for the newly introduced features. Project:

[23/27] flink git commit: [FLINK-3755] Ignore QueryableStateITCase

[FLINK-3755] Ignore QueryableStateITCase This doesn't work yet because the state query machinery is not yet properly aware of key-grouped state. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2b7a8d68 Tree:

[26/27] flink git commit: [FLINK-3755] Fix variety of test problems cause by Keyed-State Refactoring

[FLINK-3755] Fix variety of test problems cause by Keyed-State Refactoring Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f44b57cc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f44b57cc Diff:

[19/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

http://git-wip-us.apache.org/repos/asf/flink/blob/847ead01/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskState.java -- diff --git

[10/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java -- diff --git

[02/27] flink git commit: [FLINK-4380] Introduce KeyGroupAssigner and Max-Parallelism Parameter

http://git-wip-us.apache.org/repos/asf/flink/blob/ec975aab/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java -- diff --git

[11/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistry.java -- diff --git

[27/27] flink git commit: [FLINK-3755] Extended EventTimeWindowCheckpointITCase to test the boundaries of maxParallelism.

[FLINK-3755] Extended EventTimeWindowCheckpointITCase to test the boundaries of maxParallelism. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f7ef82b3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f7ef82b3 Diff:

[07/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java -- diff --git

[04/27] flink git commit: [FLINK-3761] Refactor RocksDB Backend/Make Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/addd0842/flink-contrib/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksDBMergeIteratorTest.java -- diff --git

[18/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

http://git-wip-us.apache.org/repos/asf/flink/blob/847ead01/flink-runtime/src/main/java/org/apache/flink/runtime/state/ChainedStateHandle.java -- diff --git

[17/27] flink git commit: [FLINK-4381] Refactor State to Prepare For Key-Group State Backends

http://git-wip-us.apache.org/repos/asf/flink/blob/847ead01/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java -- diff --git

[09/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapValueState.java -- diff --git

[08/27] flink git commit: [FLINK-3761] Refactor State Backends/Make Keyed State Key-Group Aware

http://git-wip-us.apache.org/repos/asf/flink/blob/4809f536/flink-runtime/src/test/java/org/apache/flink/runtime/query/netty/KvStateServerTest.java -- diff --git

[25/27] flink git commit: [hotfix] Improve Logging in CheckpointCoordinator, StreamTask, State Code

[hotfix] Improve Logging in CheckpointCoordinator, StreamTask, State Code Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/bdf9f86c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/bdf9f86c Diff:

[1/2] flink git commit: [FLINK-4539] [runtime] Reuse functionality for Physical Memory size in 'Hardware' and 'EnvironmentInformation'.

Repository: flink Updated Branches: refs/heads/master db919a585 -> 7cd9bb5f1 [FLINK-4539] [runtime] Reuse functionality for Physical Memory size in 'Hardware' and 'EnvironmentInformation'. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [hotfix] [cassandra connector] Fix minor issues in CassandraConnectorTest.

[hotfix] [cassandra connector] Fix minor issues in CassandraConnectorTest. The test now properly uses and reuses a mini cluster, rather than spawning a local environment for each test. This also properly renames the CassandraConnectorTest to CassandraConnectorITCase Project:

[2/3] flink git commit: [FLINK-4363] Implement TaskManager basic startup of all components in java

[FLINK-4363] Implement TaskManager basic startup of all components in java This closes #2400 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/806f2f14 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/806f2f14 Diff:

[3/3] flink git commit: [FLINK-4516] leader election of resourcemanager

[FLINK-4516] leader election of resourcemanager - add serial rpc service - add a special rpcService implementation which directly executes the asynchronous calls serially one by one, it is just for testcase - Change ResourceManagerLeaderContender code and TestingSerialRpcService code - override

[1/3] flink git commit: [FLINK-4347][cluster management] Implement SlotManager core

Repository: flink Updated Branches: refs/heads/flip-6 5d71a552a -> 454bf51b0 [FLINK-4347][cluster management] Implement SlotManager core This closes #2388 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4abfd9b Tree:

flink git commit: [hotfix] [table] Add docs about SQL's lexical policy

Repository: flink Updated Branches: refs/heads/master b7d83899a -> db919a585 [hotfix] [table] Add docs about SQL's lexical policy Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/db919a58 Tree: