This is an automated email from the ASF dual-hosted git repository.
yuxia 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 a0abed0ff [hotfix] fix typo in tiering enumerator (#2034)
a0abed0ff is described below
commit a0abed0ff9dd6630c989a040415418bf95928c74
Author: Giannis Polyzos <[email protected]>
AuthorDate: Thu Nov 27 03:40:49 2025 +0200
[hotfix] fix typo in tiering enumerator (#2034)
---
.../fluss/flink/tiering/source/enumerator/TieringSourceEnumerator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/enumerator/TieringSourceEnumerator.java
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/enumerator/TieringSourceEnumerator.java
index 7b670bc15..1ef73eb39 100644
---
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/enumerator/TieringSourceEnumerator.java
+++
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/tiering/source/enumerator/TieringSourceEnumerator.java
@@ -163,7 +163,7 @@ public class TieringSourceEnumerator
// reader may be failed, skip this request.
return;
}
- LOG.info("TiringSourceReader {} requests split.", subtaskId);
+ LOG.info("TieringSourceReader {} requests split.", subtaskId);
readersAwaitingSplit.add(subtaskId);
this.context.callAsync(
this::requestTieringTableSplitsViaHeartBeat,
this::generateAndAssignSplits);