diff --git a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceITCase.java b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceITCase.java
index 3018c9af32..70d11a676f 100644
--- a/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceITCase.java
+++ b/flink-connector-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceITCase.java
@@ -42,7 +42,7 @@
 import org.junit.rules.TemporaryFolder;
 import org.junit.rules.Timeout;
 
-import java.lang.reflect.Method;
+import java.lang.reflect.Field;
 import java.sql.SQLException;
 import java.time.ZoneId;
 import java.util.ArrayList;
@@ -557,9 +557,9 @@ private StreamExecutionEnvironment getStreamExecutionEnvironment(
             Class<?> clazz =
                     classLoader.loadClass(
                             "org.apache.flink.streaming.api.environment.StreamExecutionEnvironment");
-            Method getConfigurationMethod = clazz.getDeclaredMethod("getConfiguration");
-            getConfigurationMethod.setAccessible(true);
-            Configuration configuration = (Configuration) getConfigurationMethod.invoke(env);
+            Field field = clazz.getDeclaredField("configuration");
+            field.setAccessible(true);
+            Configuration configuration = (Configuration) field.get(env);
             configuration.setString(SavepointConfigOptions.SAVEPOINT_PATH, finishedSavePointPath);
         }
         env.setParallelism(parallelism);