You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2015/12/17 22:54:24 UTC
[5/5] nifi git commit: NIFI-108: Add clusterNodeId to
FlowFileSummaryDTO
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 <ma...@hotmail.com>
Authored: Thu Dec 17 16:54:13 2015 -0500
Committer: Mark Payne <ma...@hotmail.com>
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