[hotfix][starrocks] Fix StarRocks FE startup failure due to insufficient disk space available

This closes #3508.
pull/3449/head
yuxiqian 6 months ago committed by GitHub
parent f6d1d4810a
commit 3315be3c8f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

@ -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);

@ -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();

@ -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;

Loading…
Cancel
Save