From 66a632be7e05802a7635203b37c179e7c79c18ff Mon Sep 17 00:00:00 2001 From: Jialiang Tan Date: Mon, 8 Jul 2024 17:38:44 -0700 Subject: [PATCH] [native] Fix driver count reporting from worker --- presto-native-execution/presto_cpp/main/PrestoTask.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/presto-native-execution/presto_cpp/main/PrestoTask.cpp b/presto-native-execution/presto_cpp/main/PrestoTask.cpp index 4be0956d54df..229be115e4d8 100644 --- 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) {