flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tillrohrmann <...@git.apache.org>
Subject [GitHub] flink pull request #4286: [FLINK-7135] [flip6] Pass in proper configuration ...
Date Fri, 07 Jul 2017 18:03:35 GMT
GitHub user tillrohrmann opened a pull request:


    [FLINK-7135] [flip6] Pass in proper configuration to Dispatcher component

    This PR is based on #4259, #4260 and #4261.
    The `Dispatcher` component should get passed in the proper `Configuration` instance from
the `SessionClusterEntrypoint`.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/tillrohrmann/flink passInConfigurationToDispatcher

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #4286
commit 6c313e0ecc8ff84aee9403acbc60efa31d49f69e
Author: Till Rohrmann <trohrmann@apache.org>
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

commit 44abd04f328a60d3d25f74454ad04bd5c79fc258
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2017-07-05T11:38:35Z

    [FLINK-7105] Make ActorSystems non daemonic
    In order to not having to explicitly wait on the termination of an ActorSystem
    in the main thread, we now create the ActorSystems in non-daemonic mode. That
    way the process won't terminate if there is still an active actor.

commit 4a2b08645a2e7d80c7404b6af6f396178de19e33
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2017-07-06T15:16:18Z

    [FLINK-7082] Add generic entry point for session and per-job clusters

commit cacde44d9cec26e77836c56782b620d2e6d4979d
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2017-07-07T17:57:10Z

    [FLINK-7135] [flip6] Pass in proper configuration to Dispatcher component


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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message