Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4615 

- processor status is set to the ProcessorStatusDTO object
- This closes #2276
This commit is contained in:
sbouchex 2017-11-17 14:25:16 +01:00 committed by Matt Gilman
parent 2da72f1524
commit c89d793364
No known key found for this signature in database
GPG Key ID: DF61EC19432AEE37
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/manager/StatusMerger.java
View File

@ -362,6 +362,8 @@ public class StatusMerger {
merge(target.getAggregateSnapshot(), targetReadablePermission, toMerge.getAggregateSnapshot(), toMergeReadablePermission); merge(target.getAggregateSnapshot(), targetReadablePermission, toMerge.getAggregateSnapshot(), toMergeReadablePermission);
target.setRunStatus(target.getAggregateSnapshot().getRunStatus());
if (target.getNodeSnapshots() != null) { if (target.getNodeSnapshots() != null) {
final NodeProcessorStatusSnapshotDTO nodeSnapshot = new NodeProcessorStatusSnapshotDTO(); final NodeProcessorStatusSnapshotDTO nodeSnapshot = new NodeProcessorStatusSnapshotDTO();
nodeSnapshot.setStatusSnapshot(toMerge.getAggregateSnapshot()); nodeSnapshot.setStatusSnapshot(toMerge.getAggregateSnapshot());

1
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
View File

@ -1083,6 +1083,7 @@ public final class DtoFactory {
dto.setGroupId(procStatus.getGroupId()); dto.setGroupId(procStatus.getGroupId());
dto.setName(procStatus.getName()); dto.setName(procStatus.getName());
dto.setStatsLastRefreshed(new Date()); dto.setStatsLastRefreshed(new Date());
dto.setRunStatus(procStatus.getRunStatus().toString());
final ProcessorStatusSnapshotDTO snapshot = new ProcessorStatusSnapshotDTO(); final ProcessorStatusSnapshotDTO snapshot = new ProcessorStatusSnapshotDTO();
dto.setAggregateSnapshot(snapshot); dto.setAggregateSnapshot(snapshot);