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/473
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave2_ubuntu
Build Reason: The
The Buildbot has detected a restored build 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/75
Buildbot URL: https://ci.apache.org/
Buildslave for this Build: bb_slave1_ubuntu
Build Reason: The
[FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager
The ported logic contains the task lifecycle management methods, JobManager
association and
setup of TaskManager components.
Introduce Rpc implementations for TaskManager components
Implement metrics setup
Move more
Repository: flink
Updated Branches:
refs/heads/flip-6 f863d1686 -> 8c656d925
http://git-wip-us.apache.org/repos/asf/flink/blob/8c656d92/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/exceptions/CheckpointException.java
Repository: flink
Updated Branches:
refs/heads/flip-6 0518af03a -> f863d1686
[FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService
The termination futures can be used to wait for the termination of the
respective component.
This closes #2558.
Project:
Repository: flink
Updated Branches:
refs/heads/master a079259f3 -> 6731ec1e4
http://git-wip-us.apache.org/repos/asf/flink/blob/6731ec1e/flink-streaming-connectors/flink-connector-kafka-0.9/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaTestEnvironmentImpl.java
[FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9
connector
Add a test case for Kafka's new timestamp functionality and update the
documentation.
This closes #2369
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
[FLINK-4035] Add support for Kafka 0.10.x.
This closes #2231
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/63859c64
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/63859c64
Diff: