You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gu...@apache.org on 2023/04/21 17:22:45 UTC
[flink] branch master updated: [FLINK-31878][connectors] Fix the wrong name of PauseOrResumeSplitsTask#toString
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 <ta...@gmail.com>
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="