resolve api change

gnehil · Oct 12, 2023 · d57a607 · d57a607
1 parent d367a2b
commit d57a607
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ctor-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSinkFactory.java b/...ctor-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSinkFactory.java
@@ -22,8 +22,8 @@
 import org.apache.seatunnel.api.table.catalog.CatalogTable;
 import org.apache.seatunnel.api.table.connector.TableSink;
 import org.apache.seatunnel.api.table.factory.Factory;
-import org.apache.seatunnel.api.table.factory.TableFactoryContext;
 import org.apache.seatunnel.api.table.factory.TableSinkFactory;
+import org.apache.seatunnel.api.table.factory.TableSinkFactoryContext;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.connectors.doris.config.DorisOptions;
 import org.apache.seatunnel.connectors.doris.sink.committer.DorisCommitInfo;
@@ -47,7 +47,7 @@ public OptionRule optionRule() {
 
     @Override
     public TableSink<SeaTunnelRow, DorisSinkState, DorisCommitInfo, DorisCommitInfo> createSink(
-            TableFactoryContext context) {
+            TableSinkFactoryContext context) {
         ReadonlyConfig config = context.getOptions();
         CatalogTable catalogTable = context.getCatalogTable();
         return () -> new DorisSink(config, catalogTable);