diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java index 40b9ea376a87..f09d3e39ae55 100644 --- a/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java +++ b/paimon-core/src/main/java/org/apache/paimon/operation/FileStoreCommitImpl.java @@ -134,7 +134,7 @@ public class FileStoreCommitImpl implements FileStoreCommit { private final List commitCallbacks; private final StatsFileHandler statsFileHandler; private final BucketMode bucketMode; - @Nullable private long commitTimeout; + private long commitTimeout; private final int commitMaxRetries; @Nullable private Lock lock; @@ -168,7 +168,7 @@ public FileStoreCommitImpl( @Nullable Integer manifestReadParallelism, List commitCallbacks, int commitMaxRetries, - @Nullable long commitTimeout) { + long commitTimeout) { this.fileIO = fileIO; this.schemaManager = schemaManager; this.tableName = tableName;