1

wuwenchi · Apr 26, 2024 · c892b8e · c892b8e
1 parent c01b9ce
commit c892b8e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java b/...e-core/src/main/java/org/apache/doris/nereids/glue/translator/PhysicalPlanTranslator.java
@@ -169,6 +169,7 @@
 import org.apache.doris.planner.HashJoinNode;
 import org.apache.doris.planner.HashJoinNode.DistributionMode;
 import org.apache.doris.planner.HiveTableSink;
+import org.apache.doris.planner.IcebergTableSink;
 import org.apache.doris.planner.IntersectNode;
 import org.apache.doris.planner.JoinNodeBase;
 import org.apache.doris.planner.MultiCastDataSink;
@@ -479,7 +480,7 @@ public PlanFragment visitPhysicalIcebergTableSink(PhysicalIcebergTableSink<? ext
             slotDesc.setIsNullable(column.isAllowNull());
             slotDesc.setAutoInc(column.isAutoInc());
         }
-        HiveTableSink sink = new HiveTableSink(icebergTableSink.getTargetTable());
+        IcebergTableSink sink = new IcebergTableSink(icebergTableSink.getTargetTable());
         rootFragment.setSink(sink);
         return rootFragment;
     }