EventQueue metrics are not exported (#945)

* Register EventQueue metrics with Coordinator
linkedin · Jul 12, 2023 · da925e6 · da925e6
1 parent 9f3c26a
commit da925e6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/datastream-server/src/main/java/com/linkedin/datastream/server/Coordinator.java b/datastream-server/src/main/java/com/linkedin/datastream/server/Coordinator.java
@@ -2439,6 +2439,9 @@ private void addComponentMetricInfos() {
       // CheckpointProvider metrics
       addMetricInfos(_coordinator._cpProvider);
 
+      // CoordinatorEventBlockingQueue metrics
+      addMetricInfos(_coordinator._eventQueue);
+
       // EventProducer metrics
       _metricInfos.addAll(EventProducer.getMetricInfos());
     }

diff --git a/...am-server/src/main/java/com/linkedin/datastream/server/CoordinatorEventBlockingQueue.java b/...am-server/src/main/java/com/linkedin/datastream/server/CoordinatorEventBlockingQueue.java
@@ -38,7 +38,7 @@
 class CoordinatorEventBlockingQueue implements MetricsAware {
 
   private static final Logger LOG = LoggerFactory.getLogger(CoordinatorEventBlockingQueue.class.getName());
-  private static final Set<BrooklinMetricInfo> METRIC_INFOS = ConcurrentHashMap.newKeySet();
+  private final Set<BrooklinMetricInfo> _metricInfos = ConcurrentHashMap.newKeySet();
 
   static final String COUNTER_KEY = "duplicateEvents";
   static final String GAUGE_KEY = "queuedEvents";
@@ -68,7 +68,7 @@ class CoordinatorEventBlockingQueue implements MetricsAware {
 
     BrooklinCounterInfo counterInfo = new BrooklinCounterInfo(MetricRegistry.name(prefix, COUNTER_KEY));
     BrooklinGaugeInfo gaugeInfo = new BrooklinGaugeInfo(MetricRegistry.name(prefix, GAUGE_KEY));
-    METRIC_INFOS.addAll(Arrays.asList(counterInfo, gaugeInfo));
+    _metricInfos.addAll(Arrays.asList(counterInfo, gaugeInfo));
   }
 
 
@@ -161,6 +161,6 @@ public boolean isEmpty() {
 
   @Override
   public List<BrooklinMetricInfo> getMetricInfos() {
-    return new ArrayList<>(METRIC_INFOS);
+    return new ArrayList<>(_metricInfos);
   }
 }