Skip to content

Commit d9863fe

Browse files
authored
NIFI-14565 Fixed Input Port Name handling in Prometheus endpoint (apache#9940)
Signed-off-by: David Handermann <exceptionfactory@apache.org>
1 parent 2cfd6f4 commit d9863fe

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/prometheusutil/PrometheusMetricsUtil.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,8 @@
2222
import org.apache.nifi.controller.status.ConnectionStatus;
2323
import org.apache.nifi.controller.status.PortStatus;
2424
import org.apache.nifi.controller.status.ProcessGroupStatus;
25-
import org.apache.nifi.controller.status.ProcessorStatus;
2625
import org.apache.nifi.controller.status.ProcessingPerformanceStatus;
26+
import org.apache.nifi.controller.status.ProcessorStatus;
2727
import org.apache.nifi.controller.status.RemoteProcessGroupStatus;
2828
import org.apache.nifi.controller.status.TransmissionStatus;
2929
import org.apache.nifi.controller.status.analytics.StatusAnalytics;
@@ -182,8 +182,8 @@ public static CollectorRegistry createNifiMetrics(NiFiMetricsRegistry nifiMetric
182182

183183
for (PortStatus portStatus : status.getInputPortStatus()) {
184184
final String portComponentId = StringUtils.isEmpty(portStatus.getId()) ? DEFAULT_LABEL_STRING : portStatus.getId();
185-
final String portComponentName = StringUtils.isEmpty(portStatus.getName()) ? DEFAULT_LABEL_STRING : portStatus.getId();
186-
final String parentId = StringUtils.isEmpty(portStatus.getGroupId()) ? DEFAULT_LABEL_STRING : portStatus.getId();
185+
final String portComponentName = StringUtils.isEmpty(portStatus.getName()) ? DEFAULT_LABEL_STRING : portStatus.getName();
186+
final String parentId = StringUtils.isEmpty(portStatus.getGroupId()) ? DEFAULT_LABEL_STRING : portStatus.getGroupId();
187187
final String portComponentType = "InputPort";
188188
nifiMetricsRegistry.setDataPoint(portStatus.getFlowFilesSent(), "AMOUNT_FLOWFILES_SENT", instanceId, portComponentType, portComponentName, portComponentId, parentId);
189189
nifiMetricsRegistry.setDataPoint(portStatus.getFlowFilesReceived(), "AMOUNT_FLOWFILES_RECEIVED", instanceId, portComponentType, portComponentName, portComponentId, parentId);

0 commit comments

Comments
 (0)