NIFI-108: Add clusterNodeId to FlowFileSummaryDTO
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/b12aba78 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/b12aba78 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/b12aba78 Branch: refs/heads/NIFI-108 Commit: b12aba7829e91b228568e5a3aa75558c3c227247 Parents: f4ef884 Author: Mark Payne <[email protected]> Authored: Thu Dec 17 16:54:13 2015 -0500 Committer: Mark Payne <[email protected]> Committed: Thu Dec 17 16:54:13 2015 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/cluster/manager/impl/WebClusterManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/b12aba78/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java index 6b43f9d..210cf52 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java @@ -2856,7 +2856,8 @@ public class WebClusterManager implements HttpClusterManager, ProtocolHandler, C ListFlowFileState state = null; int sumOfPercents = 0; boolean finished = true; - for (final ListingRequestDTO nodeRequest : listingRequestMap.values()) { + for (final Map.Entry<NodeIdentifier, ListingRequestDTO> entry : listingRequestMap.entrySet()) { + final ListingRequestDTO nodeRequest = entry.getValue(); Integer percentComplete = nodeRequest.getPercentCompleted(); if (percentComplete != null) { sumOfPercents += percentComplete; @@ -2877,6 +2878,7 @@ public class WebClusterManager implements HttpClusterManager, ProtocolHandler, C } for (final FlowFileSummaryDTO summaryDTO : nodeRequest.getFlowFileSummaries()) { + summaryDTO.setClusterNodeId(entry.getKey().getId()); flowFileSummaries.add(summaryDTO); // Keep the set from growing beyond our max
