diff --git a/presto-native-execution/presto_cpp/main/PrestoTask.cpp b/presto-native-execution/presto_cpp/main/PrestoTask.cpp index 59711501aa2f..553dd1e7cf67 100644 --- a/presto-native-execution/presto_cpp/main/PrestoTask.cpp +++ b/presto-native-execution/presto_cpp/main/PrestoTask.cpp @@ -548,6 +548,12 @@ protocol::TaskInfo PrestoTask::updateInfoLocked() { pipelineOut.outputDataSizeInBytes; } + for (const auto& driverStat : pipeline.driverStats) { + for (const auto& [name, value] : driverStat.runtimeStats) { + addRuntimeMetric(taskRuntimeStats, name, value); + } + } + for (auto j = 0; j < pipeline.operatorStats.size(); ++j) { auto& opOut = pipelineOut.operatorSummaries[j]; auto& op = pipeline.operatorStats[j];