|
|
@ -43,7 +43,6 @@ import org.junit.BeforeClass;
|
|
|
|
import org.junit.Test;
|
|
|
|
import org.junit.Test;
|
|
|
|
|
|
|
|
|
|
|
|
import java.util.Arrays;
|
|
|
|
import java.util.Arrays;
|
|
|
|
import java.util.Collections;
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
|
|
import static org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions.JDBC_URL;
|
|
|
|
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(USERNAME, StarRocksContainer.STARROCKS_USERNAME)
|
|
|
|
.set(PASSWORD, StarRocksContainer.STARROCKS_PASSWORD);
|
|
|
|
.set(PASSWORD, StarRocksContainer.STARROCKS_PASSWORD);
|
|
|
|
|
|
|
|
|
|
|
|
config.addAll(
|
|
|
|
|
|
|
|
Configuration.fromMap(
|
|
|
|
|
|
|
|
Collections.singletonMap("table.create.properties.replication_num", "1")));
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Sink<Event> starRocksSink =
|
|
|
|
Sink<Event> starRocksSink =
|
|
|
|
((FlinkSinkProvider) createStarRocksDataSink(config).getEventSinkProvider())
|
|
|
|
((FlinkSinkProvider) createStarRocksDataSink(config).getEventSinkProvider())
|
|
|
|
.getSink();
|
|
|
|
.getSink();
|
|
|
|