From bcd2ae9e6d9e839447484d9b0a5874adf61308eb Mon Sep 17 00:00:00 2001
From: SileiWu <120839632@qq.com>
Date: Sun, 25 Jun 2023 17:49:31 +0800
Subject: [PATCH] [hotfix][mysql] remove unused code (#2231)

---
 .../connector/mysql/MySqlStreamingChangeEventSource.java | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

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 b30cfb9b7..a35aa93da 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 @@ import static io.debezium.util.Strings.isNullOrEmpty;
  * 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 class MySqlStreamingChangeEventSource
         }
     }
 
-    protected void setRestoredFromCheckpoint() {
-        this.isRestoredFromCheckpoint = true;
-    }
-
     @FunctionalInterface
     private interface TableIdProvider<E extends EventData> {
         TableId getTableId(E data);