diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java index d8dfee5a02..2915618322 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LoadStmt.java @@ -161,6 +161,12 @@ public class LoadStmt extends DdlStmt { return Integer.valueOf(s); } }) + .put(CLUSTER_PROPERTY, new Function() { + @Override + public @Nullable String apply(@Nullable String s) { + return s; + } + }) .build(); public LoadStmt(LabelName label, List dataDescriptions,