[runtime] Process reaper gives log time to reach disk before killing …

…the process
VonRosenchild · Apr 29, 2015 · 8f55abe · 8f55abe
1 parent 421e4a1
commit 8f55abe
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java b/flink-runtime/src/main/java/org/apache/flink/runtime/process/ProcessReaper.java
@@ -50,6 +50,14 @@ public void onReceive(Object message) {
  String name = term.actor().path().toSerializationFormat();
  if (log != null) {
  log.error("Actor " + name + " terminated, stopping process...");
+
+ // give the log some time to reach disk
+ try {
+ Thread.sleep(100);
+ }
+ catch (InterruptedException e) {
+ // not really problem if we don't sleep...
+ }
  }
  }
  finally {