Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24653915
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -530,54 +515,109 @@ Actor with ActorLogMessages with
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24653930
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -530,54 +515,109 @@ Actor with ActorLogMessages with
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24657012
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -530,54 +515,109 @@ Actor with ActorLogMessages with
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/385#issuecomment-74236977
I think you have to add ```archive ! PoisonPill``` to the ```postStop```
method of the JobManager to shutdown the archive actor.
---
If your project is set up for
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24602575
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -653,11 +693,87 @@ object JobManager {
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24601897
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -530,54 +515,109 @@ Actor with ActorLogMessages with
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/385#discussion_r24601755
--- Diff:
flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala
---
@@ -149,7 +134,7 @@ Actor with ActorLogMessages with