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 d84b703841..9367316b20 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 @@ -688,6 +688,12 @@ public class Coordinator implements CoordInterface { } else { executionProfile.markInstances(instanceIds); } + StringBuilder ids = new StringBuilder(); + for (TUniqueId instanceId : instanceIds) { + ids.append(DebugUtil.printId(instanceId)); + ids.append(", "); + } + LOG.info("mark instances: {}", ids.toString()); if (enablePipelineEngine) { sendPipelineCtx(); @@ -2481,7 +2487,7 @@ public class Coordinator implements CoordInterface { Preconditions.checkArgument(params.isSetDetailedReport()); if (ctx.done) { - LOG.debug("Query {} fragment {} is marked done", + LOG.info("Query {} fragment {} is marked done", DebugUtil.printId(queryId), ctx.profileFragmentId); executionProfile.markOneFragmentDone(ctx.profileFragmentId); } @@ -2532,11 +2538,11 @@ public class Coordinator implements CoordInterface { if (params.isSetErrorTabletInfos()) { updateErrorTabletInfos(params.getErrorTabletInfos()); } - LOG.debug("Query {} instance {} is marked done", + LOG.info("Query {} instance {} is marked done", DebugUtil.printId(queryId), DebugUtil.printId(params.getFragmentInstanceId())); executionProfile.markOneInstanceDone(params.getFragmentInstanceId()); } else { - LOG.debug("Query {} instance {} is not marked done", + LOG.info("Query {} instance {} is not marked done", DebugUtil.printId(queryId), DebugUtil.printId(params.getFragmentInstanceId())); } } else { @@ -2597,6 +2603,8 @@ public class Coordinator implements CoordInterface { if (params.isSetErrorTabletInfos()) { updateErrorTabletInfos(params.getErrorTabletInfos()); } + LOG.info("Query {} instance {} is marked done", + DebugUtil.printId(queryId), DebugUtil.printId(params.getFragmentInstanceId())); executionProfile.markOneInstanceDone(params.getFragmentInstanceId()); } }