diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreatePolicyCommand.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreatePolicyCommand.java index 318d1b5e79..9c878fc6e2 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreatePolicyCommand.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/CreatePolicyCommand.java @@ -18,11 +18,14 @@ package org.apache.doris.nereids.trees.plans.commands; import org.apache.doris.analysis.UserIdentity; +import org.apache.doris.nereids.exceptions.AnalysisException; import org.apache.doris.nereids.trees.expressions.Expression; import org.apache.doris.nereids.trees.plans.PlanType; import org.apache.doris.nereids.trees.plans.visitor.PlanVisitor; import org.apache.doris.policy.FilterType; import org.apache.doris.policy.PolicyTypeEnum; +import org.apache.doris.qe.ConnectContext; +import org.apache.doris.qe.StmtExecutor; import java.util.List; import java.util.Map; @@ -73,4 +76,10 @@ public class CreatePolicyCommand extends Command implements ForwardWithSync { public R accept(PlanVisitor visitor, C context) { return visitor.visitCreatePolicyCommand(this, context); } + + @Override + public void run(ConnectContext ctx, StmtExecutor executor) throws Exception { + throw new AnalysisException("Not support create policy command in Nereids now"); + } } + diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java index 7ca757bcfa..2bdfba3548 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java @@ -56,7 +56,6 @@ import org.apache.doris.nereids.glue.LogicalPlanAdapter; import org.apache.doris.nereids.minidump.MinidumpUtils; import org.apache.doris.nereids.parser.NereidsParser; import org.apache.doris.nereids.stats.StatsErrorEstimator; -import org.apache.doris.nereids.trees.plans.commands.CreatePolicyCommand; import org.apache.doris.plugin.AuditEvent.EventType; import org.apache.doris.proto.Data; import org.apache.doris.qe.QueryState.MysqlStateType; @@ -387,14 +386,6 @@ public class ConnectProcessor { if (mysqlCommand == MysqlCommand.COM_QUERY && ctx.getSessionVariable().isEnableNereidsPlanner()) { try { stmts = new NereidsParser().parseSQL(originStmt); - for (StatementBase stmt : stmts) { - LogicalPlanAdapter logicalPlanAdapter = (LogicalPlanAdapter) stmt; - // TODO: remove this after we could process CreatePolicyCommand - if (logicalPlanAdapter.getLogicalPlan() instanceof CreatePolicyCommand) { - stmts = null; - break; - } - } } catch (Exception e) { // TODO: We should catch all exception here until we support all query syntax. LOG.debug("Nereids parse sql failed. Reason: {}. Statement: \"{}\".", @@ -848,3 +839,4 @@ public class ConnectProcessor { } } + diff --git a/tools/single-node-cluster/multi-fe b/tools/single-node-cluster/multi-fe old mode 100644 new mode 100755