diff --git a/fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileStatus.java b/fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileStatus.java index 9994e8566..c2940e020 100644 --- a/fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileStatus.java +++ b/fluss-common/src/main/java/com/alibaba/fluss/fs/local/LocalFileStatus.java @@ -33,7 +33,7 @@ public class LocalFileStatus implements FileStatus { /** The file this file status belongs to. */ private final File file; - /** The path of this file this file status belongs to. */ + /** The path of this file status belongs to. */ private final FsPath path; /** Cached length field, to avoid repeated native/syscalls. */ diff --git a/fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer/PaimonStoreMultiCommitter.java b/fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer/PaimonStoreMultiCommitter.java index 932f75e7b..da8bbe500 100644 --- a/fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer/PaimonStoreMultiCommitter.java +++ b/fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/sink/committer/PaimonStoreMultiCommitter.java @@ -79,7 +79,7 @@ public class PaimonStoreMultiCommitter private final LakeTableSnapshotCommitter lakeTableSnapshotCommitter; - // the commited buckets, used to help not to commit + // the committed buckets, used to help not to commit // start log offset in every commit to Fluss private final Set committedBuckets;