This is an automated email from the ASF dual-hosted git repository.
ipolyzos pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new 33f0582f [typo] fix typos commited -> committed (#1457)
33f0582f is described below
commit 33f0582f2a79720deabc61dcc287db0f33b6a7bb
Author: xiaochen <[email protected]>
AuthorDate: Mon Aug 4 13:48:33 2025 +0800
[typo] fix typos commited -> committed (#1457)
---
.../tiering/committer/TieringCommitOperator.java | 8 ++++----
.../tiering/committer/TieringCommitOperatorTest.java | 20 ++++++++++----------
.../lake/paimon/tiering/PaimonLakeCommitter.java | 4 ++--
3 files changed, 16 insertions(+), 16 deletions(-)
diff --git
a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperator.java
b/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperator.java
index 97b65efc..ffb7ecb5 100644
---
a/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperator.java
+++
b/fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperator.java
@@ -75,7 +75,7 @@ import static
com.alibaba.fluss.utils.Preconditions.checkState;
* LakeCommitter#toCommittable(List)}, and then call method {@link
LakeCommitter#commit(Object,
* Map)} to commit to lake.
*
- * <p>Finally, it will also commit the commited lake snapshot to Fluss cluster
to make Fluss aware
+ * <p>Finally, it will also commit the committed lake snapshot to Fluss
cluster to make Fluss aware
* of the tiering progress.
*/
public class TieringCommitOperator<WriteResult, Committable>
@@ -195,7 +195,7 @@ public class TieringCommitOperator<WriteResult, Committable>
// to committable
Committable committable =
lakeCommitter.toCommittable(writeResults);
- // before commit to lake, check fluss not missing any lake
snapshot commited by fluss
+ // before commit to lake, check fluss not missing any lake
snapshot committed by fluss
checkFlussNotMissingLakeSnapshot(
tablePath,
lakeCommitter,
@@ -203,7 +203,7 @@ public class TieringCommitOperator<WriteResult, Committable>
flussCurrentLakeSnapshot == null
? null
: flussCurrentLakeSnapshot.getSnapshotId());
- long commitedSnapshotId =
+ long committedSnapshotId =
lakeCommitter.commit(committable,
toBucketOffsetsProperty(logOffsets));
// commit to fluss
Map<TableBucket, Long> logEndOffsets = new HashMap<>();
@@ -211,7 +211,7 @@ public class TieringCommitOperator<WriteResult, Committable>
logEndOffsets.put(writeResult.tableBucket(),
writeResult.logEndOffset());
}
flussTableLakeSnapshotCommitter.commit(
- new FlussTableLakeSnapshot(tableId, commitedSnapshotId,
logEndOffsets));
+ new FlussTableLakeSnapshot(tableId, committedSnapshotId,
logEndOffsets));
return committable;
}
}
diff --git
a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperatorTest.java
b/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperatorTest.java
index 86c43c1f..e5e47a8f 100644
---
a/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperatorTest.java
+++
b/fluss-flink/fluss-flink-common/src/test/java/com/alibaba/fluss/flink/tiering/committer/TieringCommitOperatorTest.java
@@ -231,10 +231,10 @@ class TieringCommitOperatorTest extends FlinkTestBase {
@Test
void testTableCommitWhenFlussMissingLakeSnapshot() throws Exception {
- CommittedLakeSnapshot mockCommitedSnapshot =
+ CommittedLakeSnapshot mockCommittedSnapshot =
mockCommittedLakeSnapshot(Collections.singletonList(null), 2);
TestingLakeTieringFactory.TestingLakeCommitter testingLakeCommitter =
- new
TestingLakeTieringFactory.TestingLakeCommitter(mockCommitedSnapshot);
+ new
TestingLakeTieringFactory.TestingLakeCommitter(mockCommittedSnapshot);
committerOperator =
new TieringCommitOperator<>(
parameters,
@@ -257,15 +257,15 @@ class TieringCommitOperatorTest extends FlinkTestBase {
tablePath,
tableId,
2,
- getExpectedLogEndOffsets(tableId, mockCommitedSnapshot,
Collections.emptyMap()),
+ getExpectedLogEndOffsets(tableId, mockCommittedSnapshot,
Collections.emptyMap()),
String.format(
"The current Fluss's lake snapshot %d is less than
lake actual snapshot %d committed by Fluss for table: {tablePath=%s,
tableId=%d},"
+ " missing snapshot: %s.",
null,
- mockCommitedSnapshot.getLakeSnapshotId(),
+ mockCommittedSnapshot.getLakeSnapshotId(),
tablePath,
tableId,
- mockCommitedSnapshot));
+ mockCommittedSnapshot));
Map<TableBucket, Long> expectedLogEndOffsets = new HashMap<>();
for (int bucket = 0; bucket < 3; bucket++) {
@@ -290,10 +290,10 @@ class TieringCommitOperatorTest extends FlinkTestBase {
Map<String, Long> partitionIdByNames =
FLUSS_CLUSTER_EXTENSION.waitUntilPartitionAllReady(tablePath);
- CommittedLakeSnapshot mockCommitedSnapshot =
+ CommittedLakeSnapshot mockCommittedSnapshot =
mockCommittedLakeSnapshot(Collections.singletonList(null), 3);
TestingLakeTieringFactory.TestingLakeCommitter testingLakeCommitter =
- new
TestingLakeTieringFactory.TestingLakeCommitter(mockCommitedSnapshot);
+ new
TestingLakeTieringFactory.TestingLakeCommitter(mockCommittedSnapshot);
committerOperator =
new TieringCommitOperator<>(
parameters,
@@ -317,14 +317,14 @@ class TieringCommitOperatorTest extends FlinkTestBase {
tablePath,
tableId,
3,
- getExpectedLogEndOffsets(tableId, mockCommitedSnapshot,
Collections.emptyMap()),
+ getExpectedLogEndOffsets(tableId, mockCommittedSnapshot,
Collections.emptyMap()),
String.format(
"The current Fluss's lake snapshot %d is less than
lake actual snapshot %d committed by Fluss for table: {tablePath=%s,
tableId=%d}, missing snapshot: %s.",
null,
- mockCommitedSnapshot.getLakeSnapshotId(),
+ mockCommittedSnapshot.getLakeSnapshotId(),
tablePath,
tableId,
- mockCommitedSnapshot));
+ mockCommittedSnapshot));
}
private CommittedLakeSnapshot mockCommittedLakeSnapshot(List<Long>
partitions, int snapshotId) {
diff --git
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
index 9d7eed0b..8e16e0fc 100644
---
a/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
+++
b/fluss-lake/fluss-lake-paimon/src/main/java/com/alibaba/fluss/lake/paimon/tiering/PaimonLakeCommitter.java
@@ -167,7 +167,7 @@ public class PaimonLakeCommitter implements
LakeCommitter<PaimonWriteResult, Pai
@Nullable
private Snapshot getCommittedLatestSnapshotOfLake(String commitUser)
throws IOException {
- // get the latest snapshot commited by fluss or latest commited id
+ // get the latest snapshot committed by fluss or latest committed id
SnapshotManager snapshotManager = fileStoreTable.snapshotManager();
Long userCommittedSnapshotIdOrLatestCommitId =
fileStoreTable
@@ -182,7 +182,7 @@ public class PaimonLakeCommitter implements
LakeCommitter<PaimonWriteResult, Pai
Snapshot snapshot =
snapshotManager.tryGetSnapshot(userCommittedSnapshotIdOrLatestCommitId);
if (!snapshot.commitUser().equals(commitUser)) {
- // the snapshot is still not commited by Fluss, return directly
+ // the snapshot is still not committed by Fluss, return directly
return null;
}
return snapshot;
