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

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 <aldrin@apache.org>
This commit is contained in:
Mark Payne 2017-05-16 14:31:04 -04:00 committed by Aldrin Piri
parent 3a0004a665
commit 2f3ba57dd6
No known key found for this signature in database
GPG Key ID: 531AEBAA4CFE5D00
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/remote/StandardRemoteProcessGroup.java
View File

@ -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"); 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()) { 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"); 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 { } finally {
readLock.unlock(); readLock.unlock();