[hotfix] Try to stabilize the flaky integration tests

Author: RocMarshal

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

@@ -25,6 +25,7 @@
 import org.apache.flink.connector.jdbc.testutils.tables.TableRow;
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
+import org.apache.flink.streaming.util.RestartStrategyUtils;
 import org.apache.flink.table.api.DataTypes;
 import org.apache.flink.table.api.TableEnvironment;
 import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
@@ -133,6 +134,7 @@ void beforeEach() throws SQLException {
             inputTable.insertIntoTableValues(conn, getTestData());
         }
         env = StreamExecutionEnvironment.getExecutionEnvironment();
+        RestartStrategyUtils.configureFixedDelayRestartStrategy(env, 3, 1000L);
         tEnv = StreamTableEnvironment.create(env);
     }
 

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

@@ -56,7 +56,10 @@ public class OceanBaseDatabase extends DatabaseExtension implements OceanBaseIma
                             "/root/boot/init.d/init.sql")
                     .waitingFor(
                             Wait.forLogMessage(".*boot success!.*", 1)
-                                    .withStartupTimeout(Duration.ofMinutes(3)))
+                                    .withStartupTimeout(Duration.ofMinutes(5)))
+                    .withMode(OceanBaseCEContainer.Mode.MINI)
+                    .withEnv("OB_DATAFILE_SIZE", "2G")
+                    .withEnv("OB_LOG_DISK_SIZE", "4G")
                     .withLogConsumer(new Slf4jLogConsumer(LOG));
 
     private static OceanBaseMetadata metadata;

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

@@ -20,5 +20,5 @@
 
 /** OceanBase docker images. */
 public interface OceanBaseImages {
-    String OCEANBASE_CE_4 = "oceanbase/oceanbase-ce:4.2.1-lts";
+    String OCEANBASE_CE_4 = "oceanbase/oceanbase-ce:4.3.3.1-101000012024102216";
 }