fix

apache · Mar 4, 2024 · 1ba087b · 1ba087b
1 parent 928a473
commit 1ba087b
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 6 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/PlanType.java
@@ -80,7 +80,7 @@ public enum PlanType {
     LOGICAL_WINDOW,
 
     // physical plans
-    // logical relations
+    // physical relations
     PHYSICAL_CTE_CONSUMER,
     PHYSICAL_EMPTY_RELATION,
     PHYSICAL_ES_SCAN,
@@ -92,13 +92,13 @@ public enum PlanType {
     PHYSICAL_SCHEMA_SCAN,
     PHYSICAL_TVF_RELATION,
 
-    // logical sinks
+    // physical sinks
     PHYSICAL_FILE_SINK,
     PHYSICAL_OLAP_TABLE_SINK,
     PHYSICAL_HIVE_TABLE_SINK,
     PHYSICAL_RESULT_SINK,
 
-    // logical others
+    // physical others
     PHYSICAL_HASH_AGGREGATE,
     PHYSICAL_ASSERT_NUM_ROWS,
     PHYSICAL_CTE_PRODUCER,

diff --git a/...rc/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java b/...rc/main/java/org/apache/doris/nereids/trees/plans/commands/insert/HiveInsertExecutor.java
@@ -30,7 +30,6 @@
 import org.apache.doris.qe.ConnectContext;
 import org.apache.doris.qe.StmtExecutor;
 import org.apache.doris.transaction.TransactionState;
-import org.apache.doris.transaction.TransactionStatus;
 
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;

diff --git a/...core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java b/...core/src/main/java/org/apache/doris/nereids/trees/plans/logical/LogicalHiveTableSink.java
@@ -39,7 +39,7 @@
 import java.util.Optional;
 
 /**
- * logical olap table sink for insert command
+ * logical hive table sink for insert command
  */
 public class LogicalHiveTableSink<CHILD_TYPE extends Plan> extends LogicalSink<CHILD_TYPE>
         implements Sink, PropagateFuncDeps {

diff --git a/...re/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java b/...re/src/main/java/org/apache/doris/nereids/trees/plans/physical/PhysicalHiveTableSink.java
@@ -38,7 +38,7 @@
 import java.util.Objects;
 import java.util.Optional;
 
-/** abstract physical sink */
+/** abstract physical hive sink */
 public class PhysicalHiveTableSink<CHILD_TYPE extends Plan> extends PhysicalSink<CHILD_TYPE> implements Sink {
 
     private final HMSExternalDatabase database;