diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java index 8ee4b46d4..64de06651 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java @@ -389,6 +389,7 @@ public class HoodieAppendHandle extends recordItr = null; if (writer != null) { writer.close(); + writer = null; // update final size, once for all log files for (WriteStatus status: statuses) {