diff --git a/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp b/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp index 2e8de3a5eccd..abd2df095e0b 100644 --- a/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp +++ b/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp @@ -60,8 +60,6 @@ folly::StringPiece getCounterForBlockingReason( return kCounterNumBlockedWaitForMemoryDrivers; case velox::exec::BlockingReason::kWaitForConnector: return kCounterNumBlockedWaitForConnectorDrivers; - case velox::exec::BlockingReason::kWaitForSpill: - return kCounterNumBlockedWaitForSpillDrivers; case velox::exec::BlockingReason::kYield: return kCounterNumBlockedYieldDrivers; case velox::exec::BlockingReason::kNotBlocked: @@ -333,16 +331,20 @@ void PeriodicTaskManager::updateTaskStats() { RECORD_METRIC_VALUE( kCounterNumTasksBytesProcessed, taskManager_->getBytesProcessed()); RECORD_METRIC_VALUE( - kCounterNumTasksRunning, taskNumbers[velox::exec::TaskState::kRunning]); + kCounterNumTasksRunning, + taskNumbers[static_cast(velox::exec::TaskState::kRunning)]); RECORD_METRIC_VALUE( - kCounterNumTasksFinished, taskNumbers[velox::exec::TaskState::kFinished]); + kCounterNumTasksFinished, + taskNumbers[static_cast(velox::exec::TaskState::kFinished)]); RECORD_METRIC_VALUE( kCounterNumTasksCancelled, - taskNumbers[velox::exec::TaskState::kCanceled]); + taskNumbers[static_cast(velox::exec::TaskState::kCanceled])); RECORD_METRIC_VALUE( - kCounterNumTasksAborted, taskNumbers[velox::exec::TaskState::kAborted]); + kCounterNumTasksAborted, + taskNumbers[static_cast(velox::exec::TaskState::kAborted)]); RECORD_METRIC_VALUE( - kCounterNumTasksFailed, taskNumbers[velox::exec::TaskState::kFailed]); + kCounterNumTasksFailed, + taskNumbers[static_cast(velox::exec::TaskState::kFailed)]); const auto driverCounts = taskManager_->getDriverCounts(); RECORD_METRIC_VALUE(kCounterNumQueuedDrivers, driverCounts.numQueuedDrivers); diff --git a/presto-native-execution/presto_cpp/main/PrestoTask.cpp b/presto-native-execution/presto_cpp/main/PrestoTask.cpp index 50850cdeb763..dd970bf9fe43 100644 --- a/presto-native-execution/presto_cpp/main/PrestoTask.cpp +++ b/presto-native-execution/presto_cpp/main/PrestoTask.cpp @@ -40,15 +40,15 @@ namespace { protocol::TaskState toPrestoTaskState(exec::TaskState state) { switch (state) { - case exec::kRunning: + case exec::TaskState::kRunning: return protocol::TaskState::RUNNING; - case exec::kFinished: + case exec::TaskState::kFinished: return protocol::TaskState::FINISHED; - case exec::kCanceled: + case exec::TaskState::kCanceled: return protocol::TaskState::CANCELED; - case exec::kFailed: + case exec::TaskState::kFailed: return protocol::TaskState::FAILED; - case exec::kAborted: + case exec::TaskState::kAborted: [[fallthrough]]; default: return protocol::TaskState::ABORTED; diff --git a/presto-native-execution/presto_cpp/main/common/Counters.cpp b/presto-native-execution/presto_cpp/main/common/Counters.cpp index 8f6d1b340f72..cb41f526ac8d 100644 --- a/presto-native-execution/presto_cpp/main/common/Counters.cpp +++ b/presto-native-execution/presto_cpp/main/common/Counters.cpp @@ -72,8 +72,6 @@ void registerPrestoMetrics() { DEFINE_METRIC( kCounterNumBlockedWaitForConnectorDrivers, facebook::velox::StatType::AVG); - DEFINE_METRIC( - kCounterNumBlockedWaitForSpillDrivers, facebook::velox::StatType::AVG); DEFINE_METRIC(kCounterNumBlockedYieldDrivers, facebook::velox::StatType::AVG); DEFINE_METRIC(kCounterNumStuckDrivers, facebook::velox::StatType::AVG); DEFINE_METRIC( diff --git a/presto-native-execution/presto_cpp/main/common/Counters.h b/presto-native-execution/presto_cpp/main/common/Counters.h index 9daf442aacc9..c6a6c97d82d3 100644 --- a/presto-native-execution/presto_cpp/main/common/Counters.h +++ b/presto-native-execution/presto_cpp/main/common/Counters.h @@ -96,8 +96,6 @@ constexpr folly::StringPiece kCounterNumBlockedWaitForMemoryDrivers{ "presto_cpp.num_blocked_wait_for_memory_drivers"}; constexpr folly::StringPiece kCounterNumBlockedWaitForConnectorDrivers{ "presto_cpp.num_blocked_wait_for_connector_drivers"}; -constexpr folly::StringPiece kCounterNumBlockedWaitForSpillDrivers{ - "presto_cpp.num_blocked_wait_for_spill_drivers"}; constexpr folly::StringPiece kCounterNumBlockedYieldDrivers{ "presto_cpp.num_blocked_yield_drivers"}; constexpr folly::StringPiece kCounterNumStuckDrivers{ diff --git a/presto-native-execution/velox b/presto-native-execution/velox index 2b5e9f1a5c69..1ce3c7ad2f83 160000 --- a/presto-native-execution/velox +++ b/presto-native-execution/velox @@ -1 +1 @@ -Subproject commit 2b5e9f1a5c6907d5b18b47d5aadbe4062bc42edf +Subproject commit 1ce3c7ad2f8348c2e0edf6fe2185086b09d8bdc7