nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From marka...@apache.org
Subject nifi git commit: NIFI-4372 Wait processor - recommend prioritizer in documentation. This closes #2139.
Date Wed, 04 Oct 2017 20:03:07 GMT
Repository: nifi
Updated Branches:
  refs/heads/master f1bd86600 -> ea2c91f9d


NIFI-4372 Wait processor - recommend prioritizer in documentation. This closes #2139.


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ea2c91f9
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ea2c91f9
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ea2c91f9

Branch: refs/heads/master
Commit: ea2c91f9d052016390c07bbc06fd7f8c734d373b
Parents: f1bd866
Author: Pierre Villard <pierre.villard.fr@gmail.com>
Authored: Sat Sep 9 19:21:47 2017 +0200
Committer: Mark Payne <markap14@hotmail.com>
Committed: Wed Oct 4 16:02:52 2017 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/nifi/processors/standard/Wait.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/ea2c91f9/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java
index 4e5ae5d..928d179 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/Wait.java
@@ -78,6 +78,8 @@ import static org.apache.nifi.processor.FlowFileFilter.FlowFileFilterResult.REJE
         + "In order to wait for all fragments to be processed, connect the 'original' relationship
to a Wait processor, and the 'splits' relationship to "
         + "a corresponding Notify processor. Configure the Notify and Wait processors to
use the '${fragment.identifier}' as the value "
         + "of 'Release Signal Identifier', and specify '${fragment.count}' as the value of
'Target Signal Count' in the Wait processor."
+
+        + "It is recommended to use a prioritizer (for instance First In First Out) when
using the 'wait' relationship as a loop."
 )
 @WritesAttributes({
         @WritesAttribute(attribute = "wait.start.timestamp", description = "All FlowFiles
will have an attribute 'wait.start.timestamp', which sets the "
@@ -190,7 +192,8 @@ public class Wait extends AbstractProcessor {
 
     public static final AllowableValue WAIT_MODE_TRANSFER_TO_WAIT = new AllowableValue("wait",
"Transfer to wait relationship",
             "Transfer a FlowFile to the 'wait' relationship when whose release signal has
not been notified yet." +
-                    " This mode allows other incoming FlowFiles to be enqueued by moving
FlowFiles into the wait relationship.");
+                    " This mode allows other incoming FlowFiles to be enqueued by moving
FlowFiles into the wait relationship." +
+                    " It is recommended to set a prioritizer (for instance First In First
Out) on the 'wait' relationship.");
 
     public static final AllowableValue WAIT_MODE_KEEP_IN_UPSTREAM = new AllowableValue("keep",
"Keep in the upstream connection",
             "Transfer a FlowFile to the upstream connection where it comes from when whose
release signal has not been notified yet." +


Mime
View raw message