This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0104427dc9e [FLINK-31878][connectors] Fix the wrong name of 
PauseOrResumeSplitsTask#toString
0104427dc9e is described below

commit 0104427dc9e38e898ba3865b499cc515004041c9
Author: Yuxin Tan <[email protected]>
AuthorDate: Fri Apr 21 15:55:50 2023 +0800

    [FLINK-31878][connectors] Fix the wrong name of 
PauseOrResumeSplitsTask#toString
---
 .../connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java
 
b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java
index 3988db19de5..4034ca3e97e 100644
--- 
a/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java
+++ 
b/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/fetcher/PauseOrResumeSplitsTask.java
@@ -74,7 +74,7 @@ class PauseOrResumeSplitsTask<SplitT extends SourceSplit> 
implements SplitFetche
 
     @Override
     public String toString() {
-        return "AlignmentTask{"
+        return "PauseOrResumeSplitsTask{"
                 + "splitsToResume="
                 + splitsToResume
                 + ", splitsToPause="

Reply via email to