[FLINK-4343] [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
Repository: flink
Updated Branches:
refs/heads/flip-6 9da76dcfd -> 928800569
http://git-wip-us.apache.org/repos/asf/flink/blob/92880056/flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/exceptions/SlotAllocationException.java
-
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
-
[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
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: http://git-wip-us.apache.org/repos/asf/flink/commit/fe464b
[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: http:/
[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: http://git-wip-us.a
[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: http://git-w
[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: http://git-wip-us.apa
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: http://git-wip-us.apache.org/repo
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 sche
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
12 matches
Mail list logo