(flink-connector-jdbc) branch main updated: [hotfix][OceanBase] Stabilize integration tests (#186)

[panyuepeng]

This is an automated email from the ASF dual-hosted git repository.

panyuepeng pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-jdbc.git


The following commit(s) were added to refs/heads/main by this push:
     new 96821fa3 [hotfix][OceanBase] Stabilize integration tests (#186)
96821fa3 is described below

commit 96821fa3634a50c051659cc0ed757bf45b904216
Author: Joao Boto <b...@boto.pro>
AuthorDate: Tue Feb 24 08:14:13 2026 +0100

    [hotfix][OceanBase] Stabilize integration tests (#186)
---
 .../database/catalog/OceanBaseMysqlCatalogITCase.java          |  4 ++--
 .../connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java  | 10 ++++++++++
 .../connector/jdbc/oceanbase/testutils/OceanBaseImages.java    |  2 +-
 3 files changed, 13 insertions(+), 3 deletions(-)

diff --git 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseMysqlCatalogITCase.java
 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseMysqlCatalogITCase.java
index 7231521a..dec4733a 100644
--- 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseMysqlCatalogITCase.java
+++ 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/database/catalog/OceanBaseMysqlCatalogITCase.java
@@ -200,7 +200,7 @@ public class OceanBaseMysqlCatalogITCase extends 
OceanBaseCatalogITCaseBase
                         DataTypes.DECIMAL(11, 0)),
                 field("col_double", dbType("double"), DataTypes.DOUBLE()),
                 field("col_double_unsigned", dbType("double unsigned"), 
DataTypes.DOUBLE()),
-                field("col_enum", dbType("enum('enum1','enum2','enum11')"), 
DataTypes.VARCHAR(6)),
+                field("col_enum", dbType("enum('enum1','enum2','enum11')"), 
DataTypes.CHAR(6)),
                 field("col_float", dbType("float"), DataTypes.FLOAT()),
                 field("col_float_unsigned", dbType("float unsigned"), 
DataTypes.FLOAT()),
                 field("col_int", dbType("int(11)"), DataTypes.INT()),
@@ -223,7 +223,7 @@ public class OceanBaseMysqlCatalogITCase extends 
OceanBaseCatalogITCaseBase
                         DataTypes.DECIMAL(11, 0)),
                 field("col_real", dbType("double"), DataTypes.DOUBLE()),
                 field("col_real_unsigned", dbType("double unsigned"), 
DataTypes.DOUBLE()),
-                field("col_set", dbType("set('set_ele1','set_ele12')"), 
DataTypes.VARCHAR(18)),
+                field("col_set", dbType("set('set_ele1','set_ele12')"), 
DataTypes.CHAR(18)),
                 field("col_smallint", dbType("smallint(6)"), 
DataTypes.SMALLINT()),
                 field("col_smallint_unsigned", dbType("smallint(5) unsigned"), 
DataTypes.INT()),
                 field("col_text", dbType("text"), DataTypes.VARCHAR(65535)),
diff --git 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java
 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java
index 92731ac1..a35c83a8 100644
--- 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java
+++ 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseDatabase.java
@@ -48,6 +48,16 @@ public class OceanBaseDatabase extends DatabaseExtension 
implements OceanBaseIma
     private static final OceanBaseCEContainer CONTAINER =
             new OceanBaseCEContainer(OCEANBASE_CE_4)
                     .withPassword("123456")
+                    // Resource Strategy: mini ensures lowest possible 
footprint
+                    .withEnv("MODE", "mini")
+                    // Memory Optimization: Lower limit manually
+                    .withEnv("OB_MEMORY_LIMIT", "2G")
+                    .withEnv("OB_SYSTEM_MEMORY", "1G")
+                    // Storage Optimization: Minimize pre-allocated file sizes
+                    .withEnv("OB_DATAFILE_SIZE", "1G")
+                    .withEnv("OB_LOG_DISK_SIZE", "2G")
+                    // Performance: Align with GitHub Runner's 2-core limit
+                    .withEnv("OB_CPU_COUNT", "2")
                     .withUrlParam("useSSL", "false")
                     .withUrlParam("serverTimezone", ZONE_OFFSET)
                     .withCopyToContainer(
diff --git 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseImages.java
 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseImages.java
index f62e9ac8..c827be79 100644
--- 
a/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseImages.java
+++ 
b/flink-connector-jdbc-oceanbase/src/test/java/org/apache/flink/connector/jdbc/oceanbase/testutils/OceanBaseImages.java
@@ -20,5 +20,5 @@ package org.apache.flink.connector.jdbc.oceanbase.testutils;
 
 /** 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.5-lts";
 }