From 909ded32aaa4cc5f70b162792e9a4216357826e1 Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Fri, 27 Mar 2015 15:06:11 -0400 Subject: [PATCH] NIFI-443: Fixed out-of-date comments/documentation --- .../tasks/ContinuallyRunConnectableTask.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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 a1219a47ac..b5b60c9bf8 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 { } // 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())