nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pvill...@apache.org
Subject [nifi] branch master updated: NIFI-6716: Prometheus Metrics Server returns 500 when a Remote Process Group used
Date Thu, 03 Oct 2019 09:08:27 GMT
This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/master by this push:
     new 261a395  NIFI-6716: Prometheus Metrics Server returns 500 when a Remote Process Group
used
261a395 is described below

commit 261a39599231aaab0115d30eaf8340fdf3801965
Author: Kotaro Terada <koterada@yahoo-corp.jp>
AuthorDate: Thu Sep 26 19:07:33 2019 +0900

    NIFI-6716: Prometheus Metrics Server returns 500 when a Remote Process Group used
    
    Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>
    
    This closes #3767.
---
 .../nifi/reporting/prometheus/api/PrometheusMetricsUtil.java     | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
index b894bee..fcf199e 100644
--- a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
+++ b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/main/java/org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java
@@ -402,10 +402,13 @@ public class PrometheusMetricsUtil {
                 AMOUNT_ITEMS_INPUT.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId, "", "", "", "")
                         .set(remoteProcessGroupStatus.getReceivedCount());
 
-                ACTIVE_REMOTE_PORT_COUNT.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId).set(remoteProcessGroupStatus.getActiveRemotePortCount());
-                INACTIVE_REMOTE_PORT_COUNT.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId).set(remoteProcessGroupStatus.getInactiveRemotePortCount());
+                ACTIVE_REMOTE_PORT_COUNT.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId, "", "", "", "")
+                        .set(remoteProcessGroupStatus.getActiveRemotePortCount());
+                INACTIVE_REMOTE_PORT_COUNT.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId, "", "", "", "")
+                        .set(remoteProcessGroupStatus.getInactiveRemotePortCount());
 
-                AVERAGE_LINEAGE_DURATION.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId).set(remoteProcessGroupStatus.getAverageLineageDuration());
+                AVERAGE_LINEAGE_DURATION.labels(instanceId, rpgComponentType, rpgComponentName,
rpgComponentId, parentId, "", "", "", "")
+                        .set(remoteProcessGroupStatus.getAverageLineageDuration());
 
                 IS_TRANSMITTING.labels(instanceId, rpgComponentType, rpgComponentName, rpgComponentId,
parentId, remoteProcessGroupStatus.getTransmissionStatus().name())
                         .set(TransmissionStatus.Transmitting.equals(remoteProcessGroupStatus.getTransmissionStatus())
? 1 : 0);


Mime
View raw message