From 6a56985fa8fd038606ae5a4d8db650afbaf881e6 Mon Sep 17 00:00:00 2001 From: Hang Ruan Date: Mon, 8 Aug 2022 21:11:32 +0800 Subject: [PATCH] [hotfix][test] Fix MySqlSourceITCase failure due to StreamExecutionEnvironment#getConfiguration returned unmodifiable object (#1446) --- .../cdc/connectors/mysql/source/MySqlSourceITCase.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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 3018c9af3..70d11a676 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.Test; 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 @@ public class MySqlSourceITCase extends MySqlSourceTestBase { 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);