You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by jo...@apache.org on 2020/01/14 17:58:53 UTC
[nifi] 02/03: NIFI-6902: This closes #3986. Added unit test for
original author's patch
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 6dbcf9d521cbda499877dce30c41602b66496ec8
Author: Matthew Burgess <ma...@apache.org>
AuthorDate: Tue Jan 14 10:49:25 2020 -0500
NIFI-6902: This closes #3986. Added unit test for original author's patch
Signed-off-by: Joe Witt <jo...@apache.org>
---
.../nifi/reporting/prometheus/TestPrometheusReportingTask.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
index aef9e0c..b39d757 100644
--- a/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
+++ b/nifi-nar-bundles/nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusReportingTask.java
@@ -27,7 +27,9 @@ import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClientBuilder;
import org.apache.http.util.EntityUtils;
+import org.apache.nifi.controller.status.PortStatus;
import org.apache.nifi.controller.status.ProcessGroupStatus;
+import org.apache.nifi.controller.status.RunStatus;
import org.apache.nifi.reporting.InitializationException;
import org.apache.nifi.reporting.prometheus.api.PrometheusMetricsUtil;
import org.apache.nifi.state.MockStateManager;
@@ -83,6 +85,14 @@ public class TestPrometheusReportingTask {
rootGroupStatus.setOutputCount(100);
rootGroupStatus.setInputCount(1000);
+ PortStatus outputPortStatus = new PortStatus();
+ outputPortStatus.setId("9876");
+ outputPortStatus.setName("out");
+ outputPortStatus.setGroupId("1234");
+ outputPortStatus.setRunStatus(RunStatus.Stopped);
+ outputPortStatus.setActiveThreadCount(1);
+
+ rootGroupStatus.setOutputPortStatus(Collections.singletonList(outputPortStatus));
}
@Test