Merge pull request #7 from barloc/fix_rm_metrics

opsnull · web-flow · commit 939a27889134 · 2024-08-22T09:44:04.000+08:00
fix QueueMetrics finder
diff --git a/yarn_resourcemanager.py b/yarn_resourcemanager.py
@@ -247,7 +247,7 @@ def get_metrics(self, beans):
         for i in range(len(beans)):
             if 'RMNMInfo' in beans[i]['name']:
                 self.get_rmnminfo_metrics(beans[i])
-            if 'QueueMetrics' in beans[i]['name'] and re.match(self.queue_regexp, beans[i]['tag.Queue']):
+            if 'name=QueueMetrics' in beans[i]['name'] and re.match(self.queue_regexp, beans[i]['tag.Queue']):
                 self.get_queue_metrics(beans[i])
             if 'ClusterMetrics' in beans[i]['name']:
                 self.get_cluster_metrics(beans[i])
