fix: skip close on bundles

apache · Oct 4, 2024 · 97e7197 · 97e7197
1 parent 0a71499
commit 97e7197
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