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 <mattyb...@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 <joew...@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