This is an automated email from the ASF dual-hosted git repository. leonard pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
commit 1778ef685a40c87da4d15184167bdbfa71bc6881 Author: gongzhongqiang <[email protected]> AuthorDate: Tue Aug 6 21:47:43 2024 +0800 Revert "[hotfix][starrocks] Fix StarRocks FE startup failure due to insufficient disk space available " This reverts commit 3315be3c8fbbdc88947e162335674ee544ae7604. --- .../connectors/starrocks/sink/StarRocksMetadataApplierITCase.java | 3 --- .../cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java | 5 ----- .../cdc/connectors/starrocks/sink/utils/StarRocksContainer.java | 6 +----- 3 files changed, 1 insertion(+), 13 deletions(-) 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 eae7b8f3a..c294dd423 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,9 +357,6 @@ 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 13308ef54..43c1faaac 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,7 +43,6 @@ 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; @@ -164,10 +163,6 @@ 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<Event> 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 a91862587..8bba7053e 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,11 +32,7 @@ import java.util.List; /** Docker container for StarRocks. */ public class StarRocksContainer extends JdbcDatabaseContainer<StarRocksContainer> { - // 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"; + private static final String DOCKER_IMAGE_NAME = "starrocks/allin1-ubuntu:3.2.6"; // exposed ports public static final int FE_HTTP_SERVICE_PORT = 8080;
