[GitHub] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-13 Thread StephanEwen
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-13 Thread StephanEwen
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-13 Thread StephanEwen
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-13 Thread tillrohrmann
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-12 Thread tillrohrmann
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-12 Thread tillrohrmann
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] flink pull request: [FLINK-1529] [jobmanager] Improve error handli...

2015-02-12 Thread tillrohrmann
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