From 4db2da40f5fc446d01e88409e9d8fed8193ea188 Mon Sep 17 00:00:00 2001 From: PengFei Li Date: Mon, 4 Dec 2023 21:07:44 +0800 Subject: [PATCH] Fix compile failure --- .../starrocks/sink/StarRocksDataSinkFactory.java | 9 ++++++--- .../starrocks/sink/StarRocksDataSinkFactoryTest.java | 4 +--- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/com/ververica/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/com/ververica/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java index b17e2cfcba..a221f08d78 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/com/ververica/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/com/ververica/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java @@ -51,9 +51,12 @@ public class StarRocksDataSinkFactory implements DataSinkFactory { @Override public DataSink createDataSink(Context context) { - StarRocksSinkOptions sinkOptions = buildSinkConnectorOptions(context.getConfiguration()); - TableCreateConfig tableCreateConfig = TableCreateConfig.from(context.getConfiguration()); - SchemaChangeConfig schemaChangeConfig = SchemaChangeConfig.from(context.getConfiguration()); + StarRocksSinkOptions sinkOptions = + buildSinkConnectorOptions(context.getFactoryConfiguration()); + TableCreateConfig tableCreateConfig = + TableCreateConfig.from(context.getFactoryConfiguration()); + SchemaChangeConfig schemaChangeConfig = + SchemaChangeConfig.from(context.getFactoryConfiguration()); return new StarRocksDataSink(sinkOptions, tableCreateConfig, schemaChangeConfig); } diff --git a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/com/ververical/cdc/connectors/starrocks/sink/StarRocksDataSinkFactoryTest.java b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/com/ververical/cdc/connectors/starrocks/sink/StarRocksDataSinkFactoryTest.java index 5a6afbd6f7..367e6bac48 100644 --- a/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/com/ververical/cdc/connectors/starrocks/sink/StarRocksDataSinkFactoryTest.java +++ b/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/com/ververical/cdc/connectors/starrocks/sink/StarRocksDataSinkFactoryTest.java @@ -49,9 +49,7 @@ public void testCreateDataSink() { DataSink dataSink = sinkFactory.createDataSink( new FactoryHelper.DefaultContext( - conf.toMap(), - conf, - Thread.currentThread().getContextClassLoader())); + conf, conf, Thread.currentThread().getContextClassLoader())); assertTrue(dataSink instanceof StarRocksDataSink); } }