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 #2456: [FLINK-4456] Replace ActorGateway in Task and Runt...
Date Thu, 01 Sep 2016 14:55:58 GMT
GitHub user tillrohrmann opened a pull request:


    [FLINK-4456] Replace ActorGateway in Task and RuntimeEnvironment

    Replaces the `ActorGateway` in `Task` and `RuntimeEnvironment` by interfaces to decouple
these components from the actors.
    - Introduces a `TaskExecutionStateListener` interface for `TaskExecutionState` update
    - Replaces the job manager `ActorGateway` by `InputSplitProvider` and `CheckpointNotifier`
    - Replaces the task manager `ActorGateway` by `TaskManagerConnection`
    The implementations using the `ActorGateways` are
    - `InputSplitProvider` --> `TaskInputSplitProvider`
    - `TaskExecutionStateListener` --> `ActorGatewayTaskExecutionStateListener`
    - `CheckpointNotifier` --> `ActorGatewayCheckpointNotifier`
    - `TaskManagerConnection` --> `ActorGatewayTaskManagerConnection`

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

    $ git pull https://github.com/tillrohrmann/flink FLINK-4456

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 #2456
commit 578b2ef0bacc57f093150e4addd56b833ebbdf05
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2016-09-01T12:41:44Z

    [FLINK-4456] Introduce TaskExecutionStateListener for Task

commit bd85b45e61160e5d86578da1e52c60ef1bde7c10
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2016-09-01T13:50:36Z

    Replace JobManagerGateway in Task by InputSplitProvider and CheckpointNotifier

commit d665583ca03e6748187ada46ce30c39704b17fd8
Author: Till Rohrmann <trohrmann@apache.org>
Date:   2016-09-01T14:36:31Z

    Replace the TaskManager ActorGateway by TaskManagerConnection in Task


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