Skip to content

Commit c5914e5

Browse files
committed
[hotfix] Try to stabilize the flaky integration tests
1 parent 0c36072 commit c5914e5

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

flink-connector-jdbc-core/src/test/java/org/apache/flink/connector/jdbc/core/table/source/JdbcDynamicTableSourceITCase.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,11 @@ void beforeEach() throws SQLException {
133133
inputTable.insertIntoTableValues(conn, getTestData());
134134
}
135135
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);
136141
tEnv = StreamTableEnvironment.create(env);
137142
}
138143

flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@ public class OceanBaseDatabase extends DatabaseExtension implements OceanBaseIma
5656
"/root/boot/init.d/init.sql")
5757
.waitingFor(
5858
Wait.forLogMessage(".*boot success!.*", 1)
59-
.withStartupTimeout(Duration.ofMinutes(3)))
59+
.withStartupTimeout(Duration.ofMinutes(5)))
6060
.withLogConsumer(new Slf4jLogConsumer(LOG));
6161

6262
private static OceanBaseMetadata metadata;

0 commit comments

Comments
 (0)