Reverted close change

apache · Nov 21, 2023 · 8ff6f25 · 8ff6f25
1 parent 15b4a6e
commit 8ff6f25
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java
@@ -844,6 +844,8 @@ public void ingestOnce() {
         streamSync.syncOnce();
       } catch (IOException e) {
         throw new HoodieIngestionException(String.format("Ingestion via %s failed with exception.", this.getClass()), e);
+      } finally {
+        close();
       }
     }