lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix redundant judgment statement (#1231)

Browse Source
This commit is contained in:
lamber-ken
2020-01-16 08:30:14 +08:00
committed by vinoth chandar
parent 2248fd9aea
commit 7aa3ce31e6
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hudi-client/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java
View File

@@ -90,6 +90,8 @@ public class HoodieAppendHandle<T extends HoodieRecordPayload> 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<T extends HoodieRecordPayload> extends HoodieWri
try {
// flush any remaining records to disk
doAppend(header);
long sizeInBytes = writer.getCurrentSize();
if (writer != null) {
sizeInBytes = writer.getCurrentSize();
writer.close();
}