[hotfix][test] fix the error in MySqlSourceITCase when adding the sav…

…epoint path
apache · Aug 4, 2022 · 08ff6d3 · 08ff6d3
1 parent a5dd0c0
commit 08ff6d3
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...-mysql-cdc/src/test/java/com/ververica/cdc/connectors/mysql/source/MySqlSourceITCase.java b/...-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);