Skip to content

Commit 03cb8b2

Browse files
committed
[hotfix][oceanbase] Fix CI test failures: set OB_MEMORY_LIMIT and fix connector identifier
1. Set OB_MEMORY_LIMIT=4G for OceanBase test container. The default 6G exceeds available memory in GitHub Actions runners when OceanBase tests run after other connector tests. 2. Fix OceanBaseFailoverITCase using 'mysql-cdc' instead of 'oceanbase-cdc' as the connector identifier, which caused failover tests to exercise the wrong connector factory.
1 parent b94d7b2 commit 03cb8b2

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseFailoverITCase.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -344,7 +344,7 @@ private void testMySqlParallelSource(
344344
? ""
345345
: ", primary key (id) not enforced")
346346
+ ") WITH ("
347-
+ " 'connector' = 'mysql-cdc',"
347+
+ " 'connector' = 'oceanbase-cdc',"
348348
+ " 'scan.incremental.snapshot.enabled' = 'true',"
349349
+ " 'hostname' = '%s',"
350350
+ " 'port' = '%s',"

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseTestUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@ public static OceanBaseContainer createOceanBaseContainer(String version, String
4545
return new OceanBaseContainer(version)
4646
.withMode(mode)
4747
.withTenantPassword(TEST_PASSWORD)
48+
.withEnv("OB_MEMORY_LIMIT", "4G")
4849
.withEnv("OB_DATAFILE_SIZE", "2G")
4950
.withEnv("OB_LOG_DISK_SIZE", "4G")
5051
.withLogConsumer(new Slf4jLogConsumer(LOG));

0 commit comments

Comments
 (0)