diff --git a/docs/config.md b/docs/config.md index ae223b40101e9de6a97dc96c0619480de5081b6b..dab6c2b0c6c6c722295ceb23f7ac31b274b95806 100644 --- a/docs/config.md +++ b/docs/config.md @@ -226,6 +226,23 @@ heartbeats to the JobManager. - `jobmanager.max-heartbeat-delay-before-failure.msecs`: The maximum time that a TaskManager hearbeat may be missing before the TaskManager is considered failed. +### Distributed Coordination (via Akka) + +- `akka.startup-timeout`: +- `akka.transport.heartbeat.interval`: +- `akka.transport.heartbeat.pause`: +- `akka.transport.threshold`: +- `akka.watch.heartbeat.interval`: +- `akka.watch.heartbeat.pause`: +- `akka.watch.threshold`: +- `akka.tcp.timeout`: +- `akka.framesize`: +- `akka.throughput`: +- `akka.log.lifecycle.events`: +- `akka.loglevel`: +- `akka.ask.timeout`: + + ### JobManager Web Frontend - `jobmanager.web.port`: Port of the JobManager's web interface that displays diff --git a/docs/internal_distributed_akka.md b/docs/internal_distributed_akka.md new file mode 100644 index 0000000000000000000000000000000000000000..f0bf8e0c2d9d44124b28f9f1861c5a70b19b0aca --- /dev/null +++ b/docs/internal_distributed_akka.md @@ -0,0 +1,41 @@ +--- +title: "Distributed Communication and Coordination via Akka" +--- + + +This page discusses the implementation of Flink's distributed communication +via Akka (http://akka.io) + + +## Actor Systems + +### JobManager + +### TaskManager + +### JobClient + + +## Actors and Messages + + +## Failure Detection + + diff --git a/docs/internal_overview.md b/docs/internal_overview.md index 549b42bec7368b7d5413db294edb1fe1c63b43c1..88fe6f6b8abbf0f9e549dd128291af78860c2bb3 100644 --- a/docs/internal_overview.md +++ b/docs/internal_overview.md @@ -35,7 +35,11 @@ or pull request that updates these documents as well.* + +- [Distributed Communication via Akka](internal_distributed_akka.html) + - - -- [How-to: Using logging in Flink](internal_logging.html) \ No newline at end of file +- [How-to: Using logging in Flink](internal_logging.html)