buildbot success in on flink-docs-release-0.10

2016-10-16 Thread buildbot
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/363 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The

buildbot success in on flink-docs-master

2016-10-16 Thread buildbot
The Buildbot has detected a restored build on builder flink-docs-master while building . Full details are available at: https://ci.apache.org/builders/flink-docs-master/builds/494 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The Nightly

[4/5] flink git commit: [FLINK-4689] [cluster management] Implement a simple slot provider for the new job manager

2016-10-16 Thread sewen
[FLINK-4689] [cluster management] Implement a simple slot provider for the new job manager Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e91b82d3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e91b82d3 Diff:

[5/5] flink git commit: [FLINK-4351] [cluster management] JobManager handle TaskManager's registration

2016-10-16 Thread sewen
[FLINK-4351] [cluster management] JobManager handle TaskManager's registration Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a19cae3b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a19cae3b Diff:

[3/5] flink git commit: [FLINK-4836] [cluster management] Add flink mini cluster (part 1)

2016-10-16 Thread sewen
[FLINK-4836] [cluster management] Add flink mini cluster (part 1) This implements - mini cluster configuration - startup / shutdown of common services (rpc, ha) - startup / shutdown of JobManager and Dispatcher Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/5] flink git commit: [FLINK-4835] [cluster management] Add embedded version of the high-availability services

2016-10-16 Thread sewen
[FLINK-4835] [cluster management] Add embedded version of the high-availability services This includes the addition of the EmbeddedLeaderService and a clean shutdown hook for all high availability services. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/5] flink git commit: [hotfix] [tests] Migrate some test tasks to Java

2016-10-16 Thread sewen
Repository: flink Updated Branches: refs/heads/flip-6 2486d3787 -> a19cae3b0 [hotfix] [tests] Migrate some test tasks to Java Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/da16b0a7 Tree:

flink git commit: [FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper

2016-10-16 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.1 9f7269808 -> fe464b424 [FLINK-4709] [core] Fix resource leak in InputStreamFSInputWrapper This closes #2581 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[1/2] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic [Forced Update!]

2016-10-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/flip-6 928800569 -> 2486d3787 (forced update) http://git-wip-us.apache.org/repos/asf/flink/blob/2486d378/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/exceptions/SlotAllocationException.java

[2/2] flink git commit: [FLINK-4360] [tm] Implement TM -> JM registration logic

2016-10-16 Thread trohrmann
[FLINK-4360] [tm] Implement TM -> JM registration logic Upon requesting a slot for a new job, the TaskManager registers this job at the JobLeaderService. The job leader service is responsible to monitor job leader changes for all registered jobs. In case of a new job leader, the service will try