fix

apache · Apr 30, 2024 · 3b89313 · 3b89313
1 parent 798a9e0
commit 3b89313
Showing 1 changed file with 2 additions and 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
@@ -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() {