flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-7135) Pass in proper Configuration to Dispatcher component
Date Fri, 07 Jul 2017 18:04:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-7135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16078461#comment-16078461

ASF GitHub Bot commented on FLINK-7135:

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


> Pass in proper Configuration to Dispatcher component
> ----------------------------------------------------
>                 Key: FLINK-7135
>                 URL: https://issues.apache.org/jira/browse/FLINK-7135
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Cluster Management, Mesos
>            Reporter: Till Rohrmann
>            Assignee: Till Rohrmann
>              Labels: flip-6
> The {{SessionClusterEntrypoint}} should pass in the proper {{Configuration}} instance
to the {{Dispatcher}} component.

This message was sent by Atlassian JIRA

View raw message