[
https://issues.apache.org/jira/browse/FLINK-4346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen updated FLINK-4346:
--------------------------------
Component/s: (was: Cluster Management)
Distributed Coordination
> 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
>
> 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/f1b45d320181284eca64126ba04f010e23757e38/flink-runtime/src/main/java/org/apache/flink/runtime/rpc
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
