From 93fe9521bf783a5a1ce84ae9af09754b58db82f5 Mon Sep 17 00:00:00 2001 From: slothever <18522955+wsjz@users.noreply.github.com> Date: Tue, 19 Mar 2024 09:55:16 +0800 Subject: [PATCH] [feature](insert)fix implement hive table sink plan (#32430) introduced by #32386 --- .../nereids/trees/plans/physical/PhysicalHiveTableSink.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java index 809a91e312..8a37bb71cc 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java @@ -45,7 +45,7 @@ import java.util.Set; import java.util.stream.Collectors; /** abstract physical hive sink */ -public class PhysicalHiveTableSink extends PhysicalSink implements Sink { +public class PhysicalHiveTableSink extends PhysicalTableSink implements Sink { private final HMSExternalDatabase database; private final HMSExternalTable targetTable;