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

[improvement](fe) skip attach profile during send fragment (#30085)

Browse Source 
Sometime attach profile may cost a lot of time in large machine with many instances.


---------

Co-authored-by: yiguolei <yiguolei@gmail.com>
This commit is contained in:
yiguolei
2024-01-18 10:00:53 +08:00
committed by yiguolei
parent 4608bcd7bf
commit d554d5478c
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -233,7 +233,6 @@ public class Coordinator implements CoordInterface {
// Input parameter
private long jobId = -1; // job which this task belongs to
private TUniqueId queryId;
private final boolean needReport;
// parallel execute
private final TUniqueId nextInstanceId;
@ -324,7 +323,6 @@ public class Coordinator implements CoordInterface {
} else {
this.queryGlobals.setTimeZone(context.getSessionVariable().getTimeZone());
}
this.needReport = context.getSessionVariable().enableProfile();
this.nextInstanceId = new TUniqueId();
nextInstanceId.setHi(queryId.hi);
nextInstanceId.setLo(queryId.lo + 1);
@ -348,7 +346,6 @@ public class Coordinator implements CoordInterface {
this.queryGlobals.setTimeZone(timezone);
this.queryGlobals.setLoadZeroTolerance(loadZeroTolerance);
this.queryOptions.setBeExecVersion(Config.be_exec_version);
this.needReport = true;
this.nextInstanceId = new TUniqueId();
nextInstanceId.setHi(queryId.hi);
nextInstanceId.setLo(queryId.lo + 1);
@ -845,8 +842,9 @@ public class Coordinator implements CoordInterface {
}
waitRpc(futures, this.timeoutDeadline - System.currentTimeMillis(), "send execution start");
}
attachInstanceProfileToFragmentProfile();
if (context != null && context.getSessionVariable().enableProfile()) {
attachInstanceProfileToFragmentProfile();
}
} finally {
unlock();
}
@ -988,8 +986,9 @@ public class Coordinator implements CoordInterface {
}
waitPipelineRpc(futures, this.timeoutDeadline - System.currentTimeMillis(), "send execution start");
}
attachInstanceProfileToFragmentProfile();
if (context != null && context.getSessionVariable().enableProfile()) {
attachInstanceProfileToFragmentProfile();
}
} finally {
unlock();
}