diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
index 25df304690..9af2adfd45 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/BrokerScanNode.java
@@ -196,10 +196,10 @@ public class BrokerScanNode extends LoadScanNode {
         params.setLineDelimiter(fileGroup.getLineDelimiter().getBytes(Charset.forName("UTF-8"))[0]);
         params.setStrictMode(strictMode);
         params.setProperties(brokerDesc.getProperties());
-        initColumns(context);
-        initWhereExpr(fileGroup.getWhereExpr(), analyzer);
         deleteCondition = fileGroup.getDeleteCondition();
         mergeType = fileGroup.getMergeType();
+        initColumns(context);
+        initWhereExpr(fileGroup.getWhereExpr(), analyzer);
     }
 
     /**