diff --git a/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java b/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
index b30cfb9b74..a35aa93da6 100644
--- a/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
+++ b/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
@@ -87,10 +87,10 @@
  * Copied from Debezium project to fix
  * https://github.com/ververica/flink-cdc-connectors/issues/1944.
  *
- * <p>Line 1428-1434 : Adjust GTID merging logic to support recovering from job which previously
+ * <p>Line 1427-1433 : Adjust GTID merging logic to support recovering from job which previously
  * specifying starting offset on start.
  *
- * <p>Line 1486 : Add more error details for some exceptions.
+ * <p>Line 1485 : Add more error details for some exceptions.
  */
 public class MySqlStreamingChangeEventSource
         implements StreamingChangeEventSource<MySqlPartition, MySqlOffsetContext> {
@@ -123,7 +123,6 @@ public class MySqlStreamingChangeEventSource
     private final MySqlConnection connection;
     private final EventDispatcher<MySqlPartition, TableId> eventDispatcher;
     private final ErrorHandler errorHandler;
-    private boolean isRestoredFromCheckpoint = false;
 
     @SingleThreadAccess("binlog client thread")
     private Instant eventTimestamp;
@@ -1563,10 +1562,6 @@ public void onEventDeserializationFailure(BinaryLogClient client, Exception ex)
         }
     }
 
-    protected void setRestoredFromCheckpoint() {
-        this.isRestoredFromCheckpoint = true;
-    }
-
     @FunctionalInterface
     private interface TableIdProvider<E extends EventData> {
         TableId getTableId(E data);