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="