diff --git a/hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareFSDataOutputStream.java b/hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareFSDataOutputStream.java index 6869be80d5742..361d418c2f7f9 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareFSDataOutputStream.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/fs/SizeAwareFSDataOutputStream.java @@ -44,7 +44,7 @@ public class SizeAwareFSDataOutputStream extends FSDataOutputStream { public SizeAwareFSDataOutputStream(Path path, FSDataOutputStream out, ConsistencyGuard consistencyGuard, Runnable closeCallback) throws IOException { - super(out, null); + super(out, null, out.getPos()); this.path = path; this.closeCallback = closeCallback; this.consistencyGuard = consistencyGuard;