NIFI-443: Fixed out-of-date comments/documentation
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/909ded32 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/909ded32 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/909ded32 Branch: refs/heads/NIFI-250 Commit: 909ded32aaa4cc5f70b162792e9a4216357826e1 Parents: 42a4f90 Author: Mark Payne <[email protected]> Authored: Fri Mar 27 15:06:11 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Fri Mar 27 15:06:11 2015 -0400 ---------------------------------------------------------------------- .../controller/tasks/ContinuallyRunConnectableTask.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/909ded32/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/tasks/ContinuallyRunConnectableTask.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/tasks/ContinuallyRunConnectableTask.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/tasks/ContinuallyRunConnectableTask.java index a1219a4..b5b60c9 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/tasks/ContinuallyRunConnectableTask.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/tasks/ContinuallyRunConnectableTask.java @@ -62,11 +62,11 @@ public class ContinuallyRunConnectableTask implements Callable<Boolean> { } // Connectable should run if the following conditions are met: - // 1. It's an Input Port or or is a Remote Input Port or has incoming FlowFiles queued - // 2. Any relationship is available (since there's only 1 - // relationship for a Connectable, we can say "any" or "all" and - // it means the same thing) - // 3. It is not yielded. + // 1. It is not yielded. + // 2. It has incoming connections with FlowFiles queued or doesn't expect incoming connections + // 3. If it is a funnel, it has an outgoing connection (this is needed because funnels are "always on"; other + // connectable components cannot even be started if they need an outbound connection and don't have one) + // 4. There is a connection for each relationship. final boolean triggerWhenEmpty = connectable.isTriggerWhenEmpty(); boolean flowFilesQueued = true; final boolean shouldRun = (connectable.getYieldExpiration() < System.currentTimeMillis())
