[nifi] 01/03: NIFI-6902 Update PrometheusReportingTask to supply correct fields for OutputPort

[joewitt]

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

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

commit eb37e7475f9e8473f3cbc64dc5fba1e086bfa417
Author: Tom <tombrisl...@gmail.com>
AuthorDate: Fri Nov 22 23:48:37 2019 +0000

    NIFI-6902 Update PrometheusReportingTask to supply correct fields for 
OutputPort
---
 .../org/apache/nifi/reporting/prometheus/api/PrometheusMetricsUtil.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 1437239..91a54a0 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
@@ -480,7 +480,7 @@ public class PrometheusMetricsUtil {
                 final String parentId = portStatus.getGroupId();
                 final String portComponentType = "OutputPort";
                 AMOUNT_FLOWFILES_SENT.labels(instanceId, portComponentType, 
portComponentName, portComponentId, 
parentId).set(portStatus.getFlowFilesSent());
-                AMOUNT_FLOWFILES_RECEIVED.labels(instanceId, 
portComponentType, portComponentName, 
portComponentId).set(portStatus.getFlowFilesReceived());
+                AMOUNT_FLOWFILES_RECEIVED.labels(instanceId, 
portComponentType, portComponentName, portComponentId, 
parentId).set(portStatus.getFlowFilesReceived());
 
                 AMOUNT_BYTES_SENT.labels(instanceId, portComponentType, 
portComponentName, portComponentId, parentId).set(portStatus.getBytesSent());
                 AMOUNT_BYTES_READ.labels(instanceId, portComponentType, 
portComponentName, portComponentId, parentId).set(portStatus.getInputBytes());