[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann updated FLINK-4346:
---------------------------------
Labels: flip-6 (was: )
> Implement basic RPC abstraction
> -------------------------------
>
> Key: FLINK-4346
> URL: https://issues.apache.org/jira/browse/FLINK-4346
> Project: Flink
> Issue Type: New Feature
> Components: Distributed Coordination
> Reporter: Stephan Ewen
> Assignee: Till Rohrmann
> Labels: flip-6
>
> As part of refactoring of the cluster management, we can introduce a new RPC
> abstraction on top of our Akka-based distributed coordination.
> It should address the following issues:
> - Add type safety to the sender and receiver of messages. We want proper
> types methods to be called, rather than haveing generic message types and
> pattern matching everywhere. This is similar to typed actors.
> - Make the message receivers testable without involving actors, i.e. the
> methods should be callable directly. When used with other component, the
> receiver will be wrapped in an actor that calls the methods based on received
> messages.
> - We want to keep the paradigm of single-threaded execution per "actor"
> There is some basic code layout in the following branch and commit:
> https://github.com/apache/flink/tree/flip-6/flink-runtime/src/main/java/org/apache/flink/runtime/rpc
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
