[incubator-inlong] branch master updated: [INLONG-2094][Agent][Bug] Fix registration bug of prometheus metric when submitting a job (#2095)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new f0a6a56  [INLONG-2094][Agent][Bug] Fix registration bug of prometheus 
metric when submitting a job (#2095)
f0a6a56 is described below

commit f0a6a560951b2383eed30b000cabed816938a791
Author: Yuanhao Ji <ts...@qq.com>
AuthorDate: Tue Jan 4 17:15:58 2022 +0800

    [INLONG-2094][Agent][Bug] Fix registration bug of prometheus metric when 
submitting a job (#2095)
---
 .../agent/plugin/metrics/SourcePrometheusMetrics.java      | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourcePrometheusMetrics.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourcePrometheusMetrics.java
index 85a931f..9fb52d5 100644
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourcePrometheusMetrics.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/metrics/SourcePrometheusMetrics.java
@@ -28,14 +28,16 @@ public class SourcePrometheusMetrics implements 
SourceMetrics {
 
     private final String tagName;
 
-    private final Counter sourceSuccessCounter = Counter.build()
+    private static final Counter SOURCE_SUCCESS_COUNTER = Counter.build()
             .name(AGENT_SOURCE_METRICS_PREFIX + SOURCE_SUCCESS_COUNTER_NAME)
             .help("The success message count in agent source since agent 
started.")
+            .labelNames("tag")
             .register();
 
-    private final Counter sourceFailCounter = Counter.build()
+    private static final Counter SOURCE_FAIL_COUNTER = Counter.build()
             .name(AGENT_SOURCE_METRICS_PREFIX + SOURCE_FAIL_COUNTER_NAME)
             .help("The failed message count in agent source since agent 
started.")
+            .labelNames("tag")
             .register();
 
     public SourcePrometheusMetrics(String tagName) {
@@ -49,21 +51,21 @@ public class SourcePrometheusMetrics implements 
SourceMetrics {
 
     @Override
     public void incSourceSuccessCount() {
-        sourceSuccessCounter.labels(tagName).inc();
+        SOURCE_SUCCESS_COUNTER.labels(tagName).inc();
     }
 
     @Override
     public long getSourceSuccessCount() {
-        return (long) sourceSuccessCounter.labels(tagName).get();
+        return (long) SOURCE_SUCCESS_COUNTER.labels(tagName).get();
     }
 
     @Override
     public void incSourceFailCount() {
-        sourceFailCounter.labels(tagName).inc();
+        SOURCE_FAIL_COUNTER.labels(tagName).inc();
     }
 
     @Override
     public long getSourceFailCount() {
-        return (long) sourceFailCounter.labels(tagName).get();
+        return (long) SOURCE_FAIL_COUNTER.labels(tagName).get();
     }
 }