[hotfix] Try to stabilize the flaky integration tests

RocMarshal · RocMarshal · commit 7e9c099a343e · 2025-12-11T19:05:48.000+08:00
diff --git a/flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSourceITCase.java b/flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSourceITCase.java
@@ -133,6 +133,11 @@ void beforeEach() throws SQLException {
             inputTable.insertIntoTableValues(conn, getTestData());
         }
         env = StreamExecutionEnvironment.getExecutionEnvironment();
+        Configuration fixedDelayRestartCfg = new Configuration();
+        fixedDelayRestartCfg.setString("restart-strategy", "fixed-delay");
+        fixedDelayRestartCfg.setString("restart-strategy.fixed-delay.attempts", "8");
+        fixedDelayRestartCfg.setString("restart-strategy.fixed-delay.delay", "1s");
+        env.configure(fixedDelayRestartCfg);
         tEnv = StreamTableEnvironment.create(env);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -133,6 +133,11 @@ void beforeEach() throws SQLException {`
`133`	`133`	`inputTable.insertIntoTableValues(conn, getTestData());`
`134`	`134`	`}`
`135`	`135`	`env = StreamExecutionEnvironment.getExecutionEnvironment();`
	`136`	`+ Configuration fixedDelayRestartCfg = new Configuration();`
	`137`	`+ fixedDelayRestartCfg.setString("restart-strategy", "fixed-delay");`
	`138`	`+ fixedDelayRestartCfg.setString("restart-strategy.fixed-delay.attempts", "8");`
	`139`	`+ fixedDelayRestartCfg.setString("restart-strategy.fixed-delay.delay", "1s");`
	`140`	`+ env.configure(fixedDelayRestartCfg);`
`136`	`141`	`tEnv = StreamTableEnvironment.create(env);`
`137`	`142`	`}`
`138`	`143`