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

See

buildbot success in on flink-docs-release-0.10

The Buildbot has detected a restored build 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/347 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave1_ubuntu Build Reason: The

flink git commit: [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls

Repository: flink Updated Branches: refs/heads/release-1.1 caa0fbb21 -> 90d77594f [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls Letting the Kafka commit block on polls means that 'notifyCheckpointComplete()' may take very long. This is mostly

[05/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

http://git-wip-us.apache.org/repos/asf/flink/blob/53ed6ada/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java -- diff --git

[07/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

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

[08/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

[FLINK-4379] [checkpoints] Introduce rescalable operator state This introduces the Operator State Backend, which stores state that is not partitioned by a key. It replaces the 'Checkpointed' interface. Additionally, this introduces CheckpointStateHandles as container for all checkpoint related

[06/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

http://git-wip-us.apache.org/repos/asf/flink/blob/53ed6ada/flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java -- diff --git

[01/10] flink git commit: [FLINK-4573] [web dashboard] Fix potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler

Repository: flink Updated Branches: refs/heads/master 477d1c5d4 -> 92f4539af [FLINK-4573] [web dashboard] Fix potential resource leak due to unclosed RandomAccessFile in TaskManagerLogHandler This closes #2556 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[09/10] flink git commit: [FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls

[FLINK-4702] [kafka connector] Commit offsets to Kafka asynchronously and don't block on polls Letting the Kafka commit block on polls means that 'notifyCheckpointComplete()' may take very long. This is mostly relevant for low-throughput Kafka topics. Project:

[02/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

http://git-wip-us.apache.org/repos/asf/flink/blob/53ed6ada/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamMockEnvironment.java -- diff --git

[04/10] flink git commit: [FLINK-4379] [checkpoints] Introduce rescalable operator state

http://git-wip-us.apache.org/repos/asf/flink/blob/53ed6ada/flink-runtime/src/test/java/org/apache/flink/runtime/state/StateBackendTestBase.java -- diff --git

[10/10] flink git commit: [FLINK-4379] [checkpoints] Fix minor bug and improve debug logging

[FLINK-4379] [checkpoints] Fix minor bug and improve debug logging Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6f8f5eb3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6f8f5eb3 Diff:

[1/2] flink git commit: [FLINK-4711] Let the Task trigger partition state requests and handle their responses

Repository: flink Updated Branches: refs/heads/master 7758571ae -> 477d1c5d4 http://git-wip-us.apache.org/repos/asf/flink/blob/477d1c5d/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java

[2/2] flink git commit: [FLINK-4711] Let the Task trigger partition state requests and handle their responses

[FLINK-4711] Let the Task trigger partition state requests and handle their responses This PR makes changes the partition state check in a way that the Task is now responsible for triggering the state check instead of the SingleInputGate. Furthermore, the operation returns a future containing