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 bd934461e9..55410a3fc0 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) {