fix: skip close on bundles (apache#32661)

mutianf · Oct 11, 2024 · 3d0aab4 · 3d0aab4
1 parent 20a45bb
commit 3d0aab4
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java b/...o/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java
@@ -2021,10 +2021,9 @@ public void close() throws IOException {
         reader.close();
         reader = null;
       }
-      if (serviceEntry != null) {
-        serviceEntry.close();
-        serviceEntry = null;
-      }
+      // Skipping closing the service entry on each bundle.
+      // In the future we'll close the Bigtable client in
+      // teardown.
     }
 
     @Override