fix: skip close on bundles (#32661)

apache · Oct 11, 2024 · 578d6d7 · 578d6d7
1 parent 7398a52
commit 578d6d7
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