Skip to content

Commit 8c8dbe7

Browse files
committed
Flink: Change maxCommittedCheckpointId to local variable in IcebergFilesCommitter
1 parent 0565753 commit 8c8dbe7

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

flink/v1.18/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,7 @@ public void initializeState(StateInitializationContext context) throws Exception
186186
// flink job even if it's restored from a snapshot created by another different flink job, so
187187
// it's safe to assign the max committed checkpoint id from restored flink job to the current
188188
// flink job.
189-
this.maxCommittedCheckpointId =
189+
long maxCommittedCheckpointId =
190190
getMaxCommittedCheckpointId(table, restoredFlinkJobId, operatorUniqueId, branch);
191191

192192
NavigableMap<Long, byte[]> uncommittedDataFiles =

0 commit comments

Comments
 (0)