external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3978 from citusdata/fix/explain_analyze 

Fix explain subplan duration
pull/3986/head
Hadi Moshayedi 2020-07-03 21:57:45 -07:00 committed by GitHub
parent 8ab47f4f37 4d217819ff
commit 23ffaabe52
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/executor/subplan_execution.c
View File

@ -22,6 +22,8 @@
#include "executor/executor.h" #include "executor/executor.h"
#include "utils/datetime.h" #include "utils/datetime.h"
#define SECOND_TO_MILLI_SECOND 1000
#define MICRO_TO_MILLI_SECOND 0.001
int MaxIntermediateResult = 1048576; /* maximum size in KB the intermediate result can grow to */ int MaxIntermediateResult = 1048576; /* maximum size in KB the intermediate result can grow to */
/* when this is true, we enforce intermediate result size limit in all executors */ /* when this is true, we enforce intermediate result size limit in all executors */
@ -86,7 +88,9 @@ ExecuteSubPlans(DistributedPlan *distributedPlan)
int durationMicrosecs = 0; int durationMicrosecs = 0;
TimestampDifference(startTimestamp, GetCurrentTimestamp(), &durationSeconds, TimestampDifference(startTimestamp, GetCurrentTimestamp(), &durationSeconds,
&durationMicrosecs); &durationMicrosecs);
subPlan->durationMillisecs = durationSeconds * 1000 * +durationMicrosecs * 10e-3;
subPlan->durationMillisecs = durationSeconds * SECOND_TO_MILLI_SECOND;
subPlan->durationMillisecs += durationMicrosecs * MICRO_TO_MILLI_SECOND;
subPlan->bytesSentPerWorker = RemoteFileDestReceiverBytesSent(copyDest); subPlan->bytesSentPerWorker = RemoteFileDestReceiverBytesSent(copyDest);
subPlan->remoteWorkerCount = list_length(remoteWorkerNodeList); subPlan->remoteWorkerCount = list_length(remoteWorkerNodeList);