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);

Reply via email to