diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java index 5a98ae1d0ec23..f4cd010da57b6 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java @@ -131,7 +131,7 @@ public class HoodieAppendHandle extends HoodieWriteHandle hoodieTable, @@ -154,7 +154,7 @@ public HoodieAppendHandle(HoodieWriteConfig config, String instantTime, HoodieTa this.sizeEstimator = new DefaultSizeEstimator(); this.statuses = new ArrayList<>(); this.recordProperties.putAll(config.getProps()); - this.attemmptNumber = taskContextSupplier.getAttemptNumberSupplier().get(); + this.attemptNumber = taskContextSupplier.getAttemptNumberSupplier().get(); } public HoodieAppendHandle(HoodieWriteConfig config, String instantTime, HoodieTable hoodieTable, @@ -459,12 +459,12 @@ protected void appendDataAndDeleteBlocks(Map header, ? HoodieRecord.RECORD_KEY_METADATA_FIELD : hoodieTable.getMetaClient().getTableConfig().getRecordKeyFieldProp(); - blocks.add(getBlock(config, pickLogDataBlockFormat(), recordList, getUpdatedHeader(header, blockSequenceNumber++, attemmptNumber, config, + blocks.add(getBlock(config, pickLogDataBlockFormat(), recordList, getUpdatedHeader(header, blockSequenceNumber++, attemptNumber, config, addBlockIdentifier()), keyField)); } if (appendDeleteBlocks && recordsToDelete.size() > 0) { - blocks.add(new HoodieDeleteBlock(recordsToDelete.toArray(new DeleteRecord[0]), getUpdatedHeader(header, blockSequenceNumber++, attemmptNumber, config, + blocks.add(new HoodieDeleteBlock(recordsToDelete.toArray(new DeleteRecord[0]), getUpdatedHeader(header, blockSequenceNumber++, attemptNumber, config, addBlockIdentifier()))); }