From 5e9a23e6439aad102550389d61ffc2c1cceb86af Mon Sep 17 00:00:00 2001 From: meiyi Date: Tue, 7 Nov 2023 19:41:44 +0800 Subject: [PATCH] [fix](prepare statement) Not supported such prepared statement if prepare a forward master sql (#26512) --- .../src/main/java/org/apache/doris/qe/StmtExecutor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 82d6188bfc..ec3a5a7958 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -531,6 +531,9 @@ public class StmtExecutor { if (logicalPlan instanceof Forward) { redirectStatus = ((Forward) logicalPlan).toRedirectStatus(); if (isForwardToMaster()) { + if (context.getCommand() == MysqlCommand.COM_STMT_PREPARE) { + throw new UserException("Forward master command is not supported for prepare statement"); + } if (isProxy) { // This is already a stmt forwarded from other FE. // If we goes here, means we can't find a valid Master FE(some error happens). @@ -704,6 +707,9 @@ public class StmtExecutor { queryAnalysisSpan.end(); } if (isForwardToMaster()) { + if (context.getCommand() == MysqlCommand.COM_STMT_PREPARE) { + throw new UserException("Forward master command is not supported for prepare statement"); + } if (isProxy) { // This is already a stmt forwarded from other FE. // If goes here, which means we can't find a valid Master FE(some error happens).