[2/2] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager

2016-10-11 Thread trohrmann
[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

[1/2] flink git commit: [FLINK-4738] [TaskManager] Port TaskManager logic to new Flip-6 TaskManager

2016-10-11 Thread trohrmann
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

flink git commit: [FLINK-4694] [rpc] Add termination futures to RpcEndpoint and RpcService

2016-10-11 Thread trohrmann
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:

buildbot success in on flink-docs-release-1.1

2016-10-11 Thread buildbot
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

buildbot failure in on flink-docs-release-0.9

2016-10-11 Thread buildbot
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

[1/3] flink git commit: [FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector

2016-10-11 Thread rmetzger
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

[2/3] flink git commit: [FLINK-4035] Refactor the Kafka 0.10 connector to be based upon the 0.9 connector

2016-10-11 Thread rmetzger
[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:

[3/3] flink git commit: [FLINK-4035] Add support for Kafka 0.10.x.

2016-10-11 Thread rmetzger
[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: