diff --git a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java
index 15d94037f..b30750c75 100644
--- a/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java
+++ b/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/SpecificStartingOffsetITCase.java
@@ -163,7 +163,6 @@ public class SpecificStartingOffsetITCase {
                                 savepointDir.toAbsolutePath().toString(),
                                 SavepointFormatType.DEFAULT)
                         .get();
-        jobClient.cancel().get();
 
         // Make some changes after the savepoint
         executeStatements(
@@ -239,7 +238,6 @@ public class SpecificStartingOffsetITCase {
                                 savepointDir.toAbsolutePath().toString(),
                                 SavepointFormatType.DEFAULT)
                         .get();
-        jobClient.cancel().get();
 
         // Make some changes after the savepoint
         executeStatements(
@@ -325,7 +323,6 @@ public class SpecificStartingOffsetITCase {
                                 savepointDir.toAbsolutePath().toString(),
                                 SavepointFormatType.DEFAULT)
                         .get();
-        jobClient.cancel().get();
 
         // Make some changes after the savepoint
         executeStatements(