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
The following commit(s) were added to refs/heads/master by this push:
new 3315be3c8 [hotfix][starrocks] Fix StarRocks FE startup failure due to
insufficient disk space available
3315be3c8 is described below
commit 3315be3c8fbbdc88947e162335674ee544ae7604
Author: yuxiqian <[email protected]>
AuthorDate: Tue Aug 6 17:47:10 2024 +0800
[hotfix][starrocks] Fix StarRocks FE startup failure due to insufficient
disk space available
This closes #3508.
---
.../connectors/starrocks/sink/StarRocksMetadataApplierITCase.java | 3 +++
.../cdc/connectors/starrocks/sink/StarRocksPipelineITCase.java | 5 +++++
.../cdc/connectors/starrocks/sink/utils/StarRocksContainer.java | 6 +++++-
3 files changed, 13 insertions(+), 1 deletion(-)
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<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 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<StarRocksContainer> {
- 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;
