diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java index a7602ea00..cbd77c60d 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java @@ -350,6 +350,7 @@ public class HoodieMergeHandle extends H if (fileWriter != null) { fileWriter.close(); + fileWriter = null; } long fileSizeInBytes = FSUtils.getFileSize(fs, newFilePath);