[hotfix] fix typo in tiering enumerator (#2034)

polyzos · web-flow · commit a0abed0ff9dd · 2025-11-27T09:40:49.000+08:00
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
@@ -163,7 +163,7 @@ public void handleSplitRequest(int subtaskId, @Nullable String requesterHostname
             // 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);

Original file line number	Diff line number	Diff line change
`@@ -163,7 +163,7 @@ public void handleSplitRequest(int subtaskId, @Nullable String requesterHostname`
`163`	`163`	`// reader may be failed, skip this request.`
`164`	`164`	`return;`
`165`	`165`	`}`
`166`		`- LOG.info("TiringSourceReader {} requests split.", subtaskId);`
	`166`	`+ LOG.info("TieringSourceReader {} requests split.", subtaskId);`
`167`	`167`	`readersAwaitingSplit.add(subtaskId);`
`168`	`168`	`this.context.callAsync(`
`169`	`169`	`this::requestTieringTableSplitsViaHeartBeat, this::generateAndAssignSplits);`