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 4752166dc58fe0b..7f06c2c18c96435 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
@@ -637,11 +637,15 @@ private void execInternal() throws Exception {
                     DebugUtil.printId(queryId), fragments.get(0).toThrift());
         }
 
+        LOG.info("test 222");
         processFragmentAssignmentAndParams();
+        LOG.info("test 222");
 
         traceInstance();
+        LOG.info("test 222");
 
         QeProcessorImpl.INSTANCE.registerInstances(queryId, instanceIds.size());
+        LOG.info("test 222");
 
         // create result receiver
         PlanFragmentId topId = fragments.get(0).getFragmentId();
@@ -649,6 +653,7 @@ private void execInternal() throws Exception {
         DataSink topDataSink = topParams.fragment.getSink();
         this.timeoutDeadline = System.currentTimeMillis() + queryOptions.getExecutionTimeout() * 1000L;
         if (topDataSink instanceof ResultSink || topDataSink instanceof ResultFileSink) {
+            LOG.info("test 222");
             TNetworkAddress execBeAddr = topParams.instanceExecParams.get(0).host;
             receiver = new ResultReceiver(queryId, topParams.instanceExecParams.get(0).instanceId,
                     addressToBackendID.get(execBeAddr), toBrpcHost(execBeAddr), this.timeoutDeadline);