diff --git a/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java b/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java index e2dbf6403..7cd343f50 100644 --- a/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java +++ b/hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java @@ -90,6 +90,8 @@ public class HoodieAppendHandle extends HoodieWri private boolean doInit = true; // Total number of bytes written during this append phase (an estimation) private long estimatedNumberOfBytesWritten; + // Total number of bytes written to file + private long sizeInBytes = 0; // Number of records that must be written to meet the max block size for a log block private int numberOfRecords = 0; // Max block size to limit to for a log block @@ -246,8 +248,9 @@ public class HoodieAppendHandle extends HoodieWri try { // flush any remaining records to disk doAppend(header); - long sizeInBytes = writer.getCurrentSize(); + if (writer != null) { + sizeInBytes = writer.getCurrentSize(); writer.close(); }