Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

 

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.

Akka configuration

Actors / Remote Actors

Messages, Tell, Ask, and Timeouts