You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 2 Next »

 

This page discusses the implementation of Flink's distributed communication via Akka (http://akka.io), which has been adopted in version 0.9. With Akka, all remote procedure calls are now realized as asynchronous messages. This mainly affects the components JobManager, `TaskManager` and `JobClient`. In the future, it is likely that even more components will be transformed into an actor, allowing them to send and process asynchronous messages.

 

  • No labels