From 7aa3ce31e6a662af2da4584b881043061a216d2e Mon Sep 17 00:00:00 2001 From: lamber-ken Date: Thu, 16 Jan 2020 08:30:14 +0800 Subject: [PATCH] [MINOR] Fix redundant judgment statement (#1231) --- .../src/main/java/org/apache/hudi/io/HoodieAppendHandle.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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(); }