Skip to content

Commit 66a632b

Browse files
tanjialiangamitkdutta
authored andcommitted
[native] Fix driver count reporting from worker
1 parent d3393a2 commit 66a632b

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

presto-native-execution/presto_cpp/main/PrestoTask.cpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -590,10 +590,10 @@ void PrestoTask::updateExecutionInfoLocked(
590590
prestoTaskStats.outputPositions = 0;
591591
prestoTaskStats.outputDataSizeInBytes = 0;
592592

593-
prestoTaskStats.totalDrivers = veloxTaskStats.numTotalSplits;
594-
prestoTaskStats.queuedDrivers = veloxTaskStats.numQueuedSplits;
595-
prestoTaskStats.runningDrivers = veloxTaskStats.numRunningSplits;
596-
prestoTaskStats.completedDrivers = veloxTaskStats.numFinishedSplits;
593+
prestoTaskStats.queuedDrivers = veloxTaskStats.numQueuedDrivers;
594+
prestoTaskStats.totalDrivers = veloxTaskStats.numTotalDrivers;
595+
prestoTaskStats.runningDrivers = veloxTaskStats.numRunningDrivers;
596+
prestoTaskStats.completedDrivers = veloxTaskStats.numCompletedDrivers;
597597

598598
prestoTaskStats.pipelines.resize(veloxTaskStats.pipelineStats.size());
599599
for (int i = 0; i < veloxTaskStats.pipelineStats.size(); ++i) {

0 commit comments

Comments
 (0)