Adding worker autoscaling support with KEDA

trinodb · Dec 15, 2024 · 52c79e9 · 52c79e9
1 parent 21bfb02
commit 52c79e9
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/charts/trino/README.md b/charts/trino/README.md
@@ -158,10 +158,10 @@ Fast distributed SQL query engine for big data analytics that helps you explore
       metadata:
         serverAddress: "http://prometheus.example.com"
         threshold: "1"
-        metricName: running_queries
+        metricName: required_workers
           query: >-
             sum by (service)
-            (avg_over_time(trino_execution_resourcegroups_InternalResourceGroup_RunningQueries{service={{ include "trino.fullname" . | quote }}}[5s]))
+            (avg_over_time(trino_execution_ClusterSizeMonitor_RequiredWorkers{service={{ include "trino.fullname" . | quote }}}[5s]))
   ```
 * `server.keda.annotations` - object, default: `{}`  
 

diff --git a/charts/trino/values.yaml b/charts/trino/values.yaml
@@ -163,10 +163,10 @@ server:
     #     metadata:
     #       serverAddress: "http://prometheus.example.com"
     #       threshold: "1"
-    #       metricName: running_queries
+    #       metricName: required_workers
     #         query: >-
     #           sum by (service)
-    #           (avg_over_time(trino_execution_resourcegroups_InternalResourceGroup_RunningQueries{service={{ include "trino.fullname" . | quote }}}[5s]))
+    #           (avg_over_time(trino_execution_ClusterSizeMonitor_RequiredWorkers{service={{ include "trino.fullname" . | quote }}}[5s]))
     # ```
     annotations: {}
     # server.keda.annotations -- Annotations to apply to the ScaledObject CRD.

diff --git a/tests/trino/test-values.yaml b/tests/trino/test-values.yaml
@@ -27,7 +27,7 @@ server:
         metadata:
           serverAddress: http://prometheus-operator-kube-p-prometheus.{{ .Release.Namespace }}:9090
           threshold: "1"
-          metricName: running_queries
+          metricName: required_workers
           query: >-
             sum by (service)
             (avg_over_time(trino_execution_ClusterSizeMonitor_RequiredWorkers{service={{ include "trino.fullname" . | quote }}}[5s]))