Merge pull request apache#31 from bsidhom/data-channel-open

Don't close data channels from environment sessions
tweise · Mar 22, 2018 · 0ee6547 · 0ee6547
2 parents 0582f9a + 7c40bde
commit 0ee6547
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();
   }
 }