Don't close data channels from environment sessions

tweise · Mar 22, 2018 · 7c40bde · 7c40bde
1 parent 0582f9a
commit 7c40bde
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../src/main/java/org/apache/beam/runners/flink/execution/JobResourceEnvironmentSession.java b/.../src/main/java/org/apache/beam/runners/flink/execution/JobResourceEnvironmentSession.java
@@ -107,6 +107,8 @@ public void close() throws Exception {
     // TODO: eventually use this for reference counting open sessions.
     this.isClosed = true;
     client.close();
-    dataServer.close();
+    // TODO: Close data server when we solve bundle completion/channel close races between runners
+    // and SDK harnesses.
+    // dataServer.close();
   }
 }