Repository: nifi Updated Branches: refs/heads/master 3a0004a66 -> 2f3ba57dd
NIFI-3914: Do not validate that remote group ports can start transmitting if there is no connection This closes #1810. Signed-off-by: Aldrin Piri <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2f3ba57d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2f3ba57d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2f3ba57d Branch: refs/heads/master Commit: 2f3ba57dd658372366672509ed0fa9fec5973f76 Parents: 3a0004a Author: Mark Payne <[email protected]> Authored: Tue May 16 14:31:04 2017 -0400 Committer: Aldrin Piri <[email protected]> Committed: Tue May 16 16:10:00 2017 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/remote/StandardRemoteProcessGroup.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/2f3ba57d/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 0cc8433..ff5e752 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 @@ -1298,7 +1298,9 @@ public class StandardRemoteProcessGroup implements RemoteProcessGroup { throw new IllegalStateException(this.getIdentifier() + " has a Connection to Port " + port.getIdentifier() + ", but that Port no longer exists on the remote system"); } - port.verifyCanStart(); + if (port.hasIncomingConnection()) { + port.verifyCanStart(); + } } for (final StandardRemoteGroupPort port : outputPorts.values()) { @@ -1310,7 +1312,9 @@ public class StandardRemoteProcessGroup implements RemoteProcessGroup { throw new IllegalStateException(this.getIdentifier() + " has a Connection to Port " + port.getIdentifier() + ", but that Port no longer exists on the remote system"); } - port.verifyCanStart(); + if (!port.getConnections().isEmpty()) { + port.verifyCanStart(); + } } } finally { readLock.unlock();
