GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/4260
[FLINK-7103] [dispatcher] Add skeletal structure of Dispatcher component
The Dispatcher is responsible for receiving job submissions, persisting the
JobGraphs,
spawning JobManager to execute the jobs and recovering the jobs in case of
a master
failure. This commit adds the basic skeleton including the RPC call for job
submission.
Add cleanup logic for finished jobs
Pass BlobService to JobManagerRunner
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink addDispatcher
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/4260.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4260
----
commit cba1cb11a3eaaea3511120fa7864028a2c47e6a5
Author: Till Rohrmann <[email protected]>
Date: 2017-07-04T21:15:52Z
[FLINK-7103] [dispatcher] Add skeletal structure of Dispatcher component
The Dispatcher is responsible for receiving job submissions, persisting the
JobGraphs,
spawning JobManager to execute the jobs and recovering the jobs in case of
a master
failure. This commit adds the basic skeleton including the RPC call for job
submission.
Add cleanup logic for finished jobs
Pass BlobService to JobManagerRunner
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
