fix routine load problem

LiBinfeng-01 · Nov 26, 2024 · 7c8f181 · 7c8f181
1 parent c396a9a
commit 7c8f181
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/parser/LogicalPlanBuilder.java
@@ -1516,7 +1516,7 @@ public LogicalPlan visitCreateRoutineLoad(CreateRoutineLoadContext ctx) {
         } else {
             throw new AnalysisException("labelParts in load should be [ctl.][db.]label");
         }
-        LabelNameInfo jobLabelInfo = new LabelNameInfo(labelName, labelDbName);
+        LabelNameInfo jobLabelInfo = new LabelNameInfo(labelDbName, labelName);
         String tableName = null;
         if (ctx.table != null) {
             tableName = ctx.table.getText();

diff --git a/...-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/LabelNameInfo.java b/...-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/LabelNameInfo.java
@@ -47,8 +47,7 @@ public LabelNameInfo() {
      * @param label tblName
      */
     public LabelNameInfo(String db, String label) {
-        Objects.requireNonNull(label, "require tbl object");
-        Objects.requireNonNull(db, "require db object");
+        Objects.requireNonNull(label, "require label object");
         this.label = label;
         if (Env.isStoredTableNamesLowerCase()) {
             this.label = label.toLowerCase();