From 1a6a232c94907ad210f35d4ec9be0528545583fb Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Fri, 9 Aug 2024 16:20:08 +0800 Subject: [PATCH 1/2] [fix](mtmv)fix can not show create mtmv use follower fe (#38794) err msg: internal error processing forward --- .../trees/plans/commands/ShowCreateMTMVCommand.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java index eb244be7afca44..7da1df6af6f30a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java @@ -17,6 +17,7 @@ package org.apache.doris.nereids.trees.plans.commands; +import org.apache.doris.analysis.StmtType; import org.apache.doris.nereids.trees.plans.PlanType; import org.apache.doris.nereids.trees.plans.commands.info.ShowCreateMTMVInfo; import org.apache.doris.nereids.trees.plans.visitor.PlanVisitor; @@ -28,7 +29,7 @@ /** * resume mtmv */ -public class ShowCreateMTMVCommand extends Command implements ForwardWithSync, NotAllowFallback { +public class ShowCreateMTMVCommand extends Command implements NoForward, NotAllowFallback { private final ShowCreateMTMVInfo showCreateMTMVInfo; public ShowCreateMTMVCommand(ShowCreateMTMVInfo showCreateMTMVInfo) { @@ -46,4 +47,9 @@ public void run(ConnectContext ctx, StmtExecutor executor) throws Exception { public R accept(PlanVisitor visitor, C context) { return visitor.visitShowCreateMTMVCommand(this, context); } + + @Override + public StmtType stmtType() { + return StmtType.SHOW; + } } From 53fd28084fd4852c130c0260e7b0bcc1b81fa28f Mon Sep 17 00:00:00 2001 From: zhangdong <493738387@qq.com> Date: Fri, 9 Aug 2024 19:37:46 +0800 Subject: [PATCH 2/2] 1 --- .../nereids/trees/plans/commands/ShowCreateMTMVCommand.java | 6 ------ 1 file changed, 6 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java index 7da1df6af6f30a..50a616231e09a4 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/ShowCreateMTMVCommand.java @@ -17,7 +17,6 @@ package org.apache.doris.nereids.trees.plans.commands; -import org.apache.doris.analysis.StmtType; import org.apache.doris.nereids.trees.plans.PlanType; import org.apache.doris.nereids.trees.plans.commands.info.ShowCreateMTMVInfo; import org.apache.doris.nereids.trees.plans.visitor.PlanVisitor; @@ -47,9 +46,4 @@ public void run(ConnectContext ctx, StmtExecutor executor) throws Exception { public R accept(PlanVisitor visitor, C context) { return visitor.visitShowCreateMTMVCommand(this, context); } - - @Override - public StmtType stmtType() { - return StmtType.SHOW; - } }