Fix compile failure

apache · Dec 4, 2023 · 4db2da4 · 4db2da4
1 parent f18bbe8
commit 4db2da4
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/...s/src/main/java/com/ververica/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java b/...s/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/.../test/java/com/ververical/cdc/connectors/starrocks/sink/StarRocksDataSinkFactoryTest.java b/.../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);
     }
 }