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 3988db19de57a..4034ca3e97ea8 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 @@ public void wakeUp() {}
 
     @Override
     public String toString() {
-        return "AlignmentTask{"
+        return "PauseOrResumeSplitsTask{"
                 + "splitsToResume="
                 + splitsToResume
                 + ", splitsToPause="