From d2691d2eb4940da0be80a0d0e8eb2c149b141f1a Mon Sep 17 00:00:00 2001 From: Stephan Ewen Date: Sun, 4 Jan 2015 23:10:01 +0100 Subject: [PATCH] [FLINK-1346] [docs] Add stubs for Akka documentation --- docs/config.md | 17 +++++++++++++ docs/internal_distributed_akka.md | 41 +++++++++++++++++++++++++++++++ docs/internal_overview.md | 10 ++++---- 3 files changed, 63 insertions(+), 5 deletions(-) create mode 100644 docs/internal_distributed_akka.md diff --git a/docs/config.md b/docs/config.md index ae223b40101..dab6c2b0c6c 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 00000000000..f0bf8e0c2d9 --- /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 549b42bec73..88fe6f6b8ab 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) -- GitLab