diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeEvent.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberEvent.java
similarity index 67%
rename from flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeEvent.java
rename to flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberEvent.java
index 60c751d74..1daca4248 100644
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeEvent.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberEvent.java
@@ -23,26 +23,26 @@ import com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader;
 
 /**
  * The {@link SourceEvent} that {@link MySqlSourceEnumerator} sends to {@link MySqlSourceReader} to
- * pass the latest finished snapshot splits size.
+ * pass the latest finished snapshot splits number.
  */
-public class LatestFinishedSplitsSizeEvent implements SourceEvent {
+public class LatestFinishedSplitsNumberEvent implements SourceEvent {
 
     private static final long serialVersionUID = 1L;
-    private final int latestFinishedSplitsSize;
+    private final int latestFinishedSplitsNumber;
 
-    public LatestFinishedSplitsSizeEvent(int latestFinishedSplitsSize) {
-        this.latestFinishedSplitsSize = latestFinishedSplitsSize;
+    public LatestFinishedSplitsNumberEvent(int latestFinishedSplitsNumber) {
+        this.latestFinishedSplitsNumber = latestFinishedSplitsNumber;
     }
 
-    public int getLatestFinishedSplitsSize() {
-        return latestFinishedSplitsSize;
+    public int getLatestFinishedSplitsNumber() {
+        return latestFinishedSplitsNumber;
     }
 
     @Override
     public String toString() {
-        return "LatestFinishedSplitsSizeEvent{"
-                + "latestFinishedSplitsSize="
-                + latestFinishedSplitsSize
+        return "LatestFinishedSplitsNumberEvent{"
+                + "latestFinishedSplitsNumber="
+                + latestFinishedSplitsNumber
                 + '}';
     }
 }
diff --git a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeRequestEvent.java b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberRequestEvent.java
similarity index 85%
rename from flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeRequestEvent.java
rename to flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberRequestEvent.java
index e96cd7378..669da0bac 100644
--- a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsSizeRequestEvent.java
+++ b/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/events/LatestFinishedSplitsNumberRequestEvent.java
@@ -23,11 +23,11 @@ import com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader;
 
 /**
  * The {@link SourceEvent} that {@link MySqlSourceReader} sends to {@link MySqlSourceEnumerator} to
- * ask the latest finished snapshot splits size.
+ * ask the latest finished snapshot splits number.
  */
-public class LatestFinishedSplitsSizeRequestEvent implements SourceEvent {
+public class LatestFinishedSplitsNumberRequestEvent implements SourceEvent {
 
     private static final long serialVersionUID = 1L;
 
-    public LatestFinishedSplitsSizeRequestEvent() {}
+    public LatestFinishedSplitsNumberRequestEvent() {}
 }