From 3b893136617682c056a4c17d8ee7d330f7d36091 Mon Sep 17 00:00:00 2001
From: eldenmoon <15605149486@163.com>
Date: Tue, 30 Apr 2024 22:14:11 +0800
Subject: [PATCH] fix

---
 fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index 99213f56e1c7824..e28893104286c68 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -36,6 +36,7 @@
 import org.apache.doris.common.util.TimeUtils;
 import org.apache.doris.load.loadv2.LoadJob;
 import org.apache.doris.metric.MetricRepo;
+import org.apache.doris.mysql.MysqlCommand;
 import org.apache.doris.nereids.stats.StatsErrorEstimator;
 import org.apache.doris.planner.DataPartition;
 import org.apache.doris.planner.DataSink;
@@ -374,7 +375,7 @@ private void initQueryOptions(ConnectContext context) {
         this.queryOptions.setExecutionTimeout(context.getExecTimeout());
         this.queryOptions.setEnableScanNodeRunSerial(context.getSessionVariable().isEnableScanRunSerial());
         this.queryOptions.setMysqlRowBinaryFormat(
-                    context.getMysqlChannel().useServerPrepStmts());
+                    context.getCommand() == MysqlCommand.COM_STMT_EXECUTE);
     }
 
     public long getJobId() {