Repository: nifi Updated Branches: refs/heads/master 998ac1c83 -> 9874d35b6
NIFI-1600: Ensure that if we move a RemoteProcessGroup, it also updates the Parent Process Group of the ports Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9874d35b Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9874d35b Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9874d35b Branch: refs/heads/master Commit: 9874d35b6befddc341833e2c65af301d99090dd7 Parents: 998ac1c Author: Mark Payne <[email protected]> Authored: Tue Mar 8 10:53:23 2016 -0500 Committer: Mark Payne <[email protected]> Committed: Tue Mar 8 12:09:45 2016 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/remote/StandardRemoteProcessGroup.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9874d35b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java index bd93446..55410a3 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java @@ -211,6 +211,12 @@ public class StandardRemoteProcessGroup implements RemoteProcessGroup { @Override public void setProcessGroup(final ProcessGroup group) { this.processGroup.set(group); + for (final RemoteGroupPort port : getInputPorts()) { + port.setProcessGroup(group); + } + for (final RemoteGroupPort port : getOutputPorts()) { + port.setProcessGroup(group); + } } public void setTargetId(final String targetId) {
