diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java index f752e0d5a..b2f6f784c 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/InputBatch.java @@ -39,9 +39,7 @@ public class InputBatch { } public InputBatch(Option batch, String checkpointForNextBatch) { - this.batch = batch; - this.checkpointForNextBatch = checkpointForNextBatch; - this.schemaProvider = null; + this(batch, checkpointForNextBatch, null); } public Option getBatch() {