[native]Add non-reclaimable operator memory reclaim attempts

prestodb · Oct 12, 2023 · c7818f1 · c7818f1
1 parent 5a08d8a
commit c7818f1
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 0 deletions.
diff --git a/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp b/presto-native-execution/presto_cpp/main/PeriodicTaskManager.cpp
@@ -543,6 +543,10 @@ void PeriodicTaskManager::updateArbitratorStatsTask() {
   REPORT_IF_NOT_ZERO(
       kCounterArbitratorFreeCapacityBytes,
       deltaArbitratorStats.freeCapacityBytes);
+  REPORT_IF_NOT_ZERO(
+      kCounterArbitratorNonReclaimableAttempts,
+      deltaArbitratorStats.numNonReclaimableAttempts);
+
   if (!deltaArbitratorStats.empty()) {
     LOG(INFO) << "Updated memory arbitrator stats: "
               << updatedArbitratorStats.toString();

diff --git a/presto-native-execution/presto_cpp/main/common/Counters.cpp b/presto-native-execution/presto_cpp/main/common/Counters.cpp
@@ -241,6 +241,8 @@ void registerPrestoCppCounters() {
       kCounterArbitratorNumReclaimedBytes, facebook::velox::StatType::SUM);
   REPORT_ADD_STAT_EXPORT_TYPE(
       kCounterArbitratorFreeCapacityBytes, facebook::velox::StatType::AVG);
+  REPORT_ADD_STAT_EXPORT_TYPE(
+      kCounterArbitratorNonReclaimableAttempts, facebook::velox::StatType::SUM);
 
   // NOTE: Metrics type exporting for file handle cache counters are in
   // PeriodicTaskManager because they have dynamic names. The following counters

diff --git a/presto-native-execution/presto_cpp/main/common/Counters.h b/presto-native-execution/presto_cpp/main/common/Counters.h
@@ -162,6 +162,9 @@ constexpr folly::StringPiece kCounterArbitratorNumReclaimedBytes{
 /// The free memory capacity in bytes.
 constexpr folly::StringPiece kCounterArbitratorFreeCapacityBytes{
     "presto_cpp.arbitrator_free_capacity_bytes"};
+/// The number of non-reclaimable operator reclaim attempts.
+constexpr folly::StringPiece kCounterArbitratorNonReclaimableAttempts{
+    "presto_cpp.arbitrator_non_reclaimable_attempts"};
 
 /// ================== Disk Spilling Counters =================