[native] Fix driver count reporting from worker

ScrapCodes · Jul 17, 2024 · 66a632b · 66a632b
1 parent d3393a2
commit 66a632b
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/presto-native-execution/presto_cpp/main/PrestoTask.cpp b/presto-native-execution/presto_cpp/main/PrestoTask.cpp
@@ -590,10 +590,10 @@ void PrestoTask::updateExecutionInfoLocked(
   prestoTaskStats.outputPositions = 0;
   prestoTaskStats.outputDataSizeInBytes = 0;
 
-  prestoTaskStats.totalDrivers = veloxTaskStats.numTotalSplits;
-  prestoTaskStats.queuedDrivers = veloxTaskStats.numQueuedSplits;
-  prestoTaskStats.runningDrivers = veloxTaskStats.numRunningSplits;
-  prestoTaskStats.completedDrivers = veloxTaskStats.numFinishedSplits;
+  prestoTaskStats.queuedDrivers = veloxTaskStats.numQueuedDrivers;
+  prestoTaskStats.totalDrivers = veloxTaskStats.numTotalDrivers;
+  prestoTaskStats.runningDrivers = veloxTaskStats.numRunningDrivers;
+  prestoTaskStats.completedDrivers = veloxTaskStats.numCompletedDrivers;
 
   prestoTaskStats.pipelines.resize(veloxTaskStats.pipelineStats.size());
   for (int i = 0; i < veloxTaskStats.pipelineStats.size(); ++i) {