Merge branch 'move_memtable_scheme_change' of https://github.com/HHof…

…littlefish777/doris into move_memtable_scheme_change
apache · Jan 1, 2024 · 52bd50a · 52bd50a
2 parents eed6950 + f86570c
commit 52bd50a
Showing 1 changed file with 5 additions and 0 deletions.
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
@@ -637,18 +637,23 @@ 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();
         FragmentExecParams topParams = fragmentExecParamsMap.get(topId);
         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);