diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java index c294dd423..eae7b8f3a 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierITCase.java @@ -357,6 +357,9 @@ public class StarRocksMetadataApplierITCase extends StarRocksSinkTestBase { .set(JDBC_URL, STARROCKS_CONTAINER.getJdbcUrl()) .set(USERNAME, StarRocksContainer.STARROCKS_USERNAME) .set(PASSWORD, StarRocksContainer.STARROCKS_PASSWORD); + config.addAll( + Configuration.fromMap( + Collections.singletonMap("table.create.properties.replication_num", "1"))); DataSink starRocksSink = createStarRocksDataSink(config); diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java index 43c1faaac..13308ef54 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java @@ -43,6 +43,7 @@ import org.junit.BeforeClass; import org.junit.Test; import java.util.Arrays; +import java.util.Collections; import java.util.List; import static org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions.JDBC_URL; @@ -163,6 +164,10 @@ public class StarRocksPipelineITCase extends StarRocksSinkTestBase { .set(USERNAME, StarRocksContainer.STARROCKS_USERNAME) .set(PASSWORD, StarRocksContainer.STARROCKS_PASSWORD); + config.addAll( + Configuration.fromMap( + Collections.singletonMap("table.create.properties.replication_num", "1"))); + Sink starRocksSink = ((FlinkSinkProvider) createStarRocksDataSink(config).getEventSinkProvider()) .getSink(); diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksContainer.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksContainer.java index 8bba7053e..a91862587 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksContainer.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/utils/StarRocksContainer.java @@ -32,7 +32,11 @@ import java.util.List; /** Docker container for StarRocks. */ public class StarRocksContainer extends JdbcDatabaseContainer { - private static final String DOCKER_IMAGE_NAME = "starrocks/allin1-ubuntu:3.2.6"; + // NOTE: StarRocks 3.x introduces free space check (> 5GB) during FE node startup + // (https://github.com/StarRocks/starrocks/pull/34813), which will fail on a typical GitHub + // runner environment. Downgraded to 2.x series for now to avoid blocking CI, and upgrade this + // after StarRocks provide a workaround for this. + private static final String DOCKER_IMAGE_NAME = "starrocks/allin1-ubuntu:2.5.21"; // exposed ports public static final int FE_HTTP_SERVICE_PORT = 8080;