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

[cleanup](insert-into) clean up some insert into log (#30063)

Browse Source
This commit is contained in:
HHoflittlefish777
2024-01-17 19:59:14 +08:00
committed by yiguolei
parent 65b5a5436a
commit 990d5d8664
5 changed files with 4 additions and 29 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,12 +688,6 @@ 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();
@ -2494,7 +2488,7 @@ public class Coordinator implements CoordInterface {
Preconditions.checkArgument(params.isSetDetailedReport());
if (ctx.done) {
LOG.info("Query {} fragment {} is marked done",
LOG.debug("Query {} fragment {} is marked done",
DebugUtil.printId(queryId), ctx.profileFragmentId);
executionProfile.markOneFragmentDone(ctx.profileFragmentId);
}
@ -2552,11 +2546,11 @@ public class Coordinator implements CoordInterface {
if (params.isSetErrorTabletInfos()) {
updateErrorTabletInfos(params.getErrorTabletInfos());
}
LOG.info("Query {} instance {} is marked done",
LOG.debug("Query {} instance {} is marked done",
DebugUtil.printId(queryId), DebugUtil.printId(params.getFragmentInstanceId()));
executionProfile.markOneInstanceDone(params.getFragmentInstanceId());
} else {
LOG.info("Query {} instance {} is not marked done",
LOG.debug("Query {} instance {} is not marked done",
DebugUtil.printId(queryId), DebugUtil.printId(params.getFragmentInstanceId()));
}
} else {
@ -2623,8 +2617,6 @@ 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());
}
}