database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improve](insert-into) add log when instance mark and done (#29636)

Browse Source
This commit is contained in:
HHoflittlefish777
2024-01-08 10:11:12 +08:00
committed by GitHub
parent c58d18147b
commit 0bdd007926
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -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());
}
}