You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by al...@apache.org on 2017/03/02 20:39:01 UTC
nifi git commit: NIFI-3547 Changing level from WARN to INFO for Wait
Processor's expected behavior
Repository: nifi
Updated Branches:
refs/heads/master d689ac561 -> ac5a7960e
NIFI-3547 Changing level from WARN to INFO for Wait Processor's expected behavior
This closes #1556.
Signed-off-by: Aldrin Piri <al...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/ac5a7960
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/ac5a7960
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/ac5a7960
Branch: refs/heads/master
Commit: ac5a7960e861c5802374bb875057253d61f8a286
Parents: d689ac5
Author: josephxsxn <jn...@hortonworks.com>
Authored: Thu Mar 2 13:51:28 2017 -0500
Committer: Aldrin Piri <al...@apache.org>
Committed: Thu Mar 2 15:37:39 2017 -0500
----------------------------------------------------------------------
.../src/main/java/org/apache/nifi/processors/standard/Wait.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/ac5a7960/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 8ae85d8..8b76ce5 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
@@ -275,7 +275,7 @@ public class Wait extends AbstractProcessor {
.asTimePeriod(TimeUnit.MILLISECONDS);
long now = System.currentTimeMillis();
if (now > (lWaitStartTimestamp + expirationDuration)) {
- logger.warn("FlowFile {} expired after {}ms", new Object[] {flowFile, (now - lWaitStartTimestamp)});
+ logger.info("FlowFile {} expired after {}ms", new Object[] {flowFile, (now - lWaitStartTimestamp)});
flowFile = copySignalAttributes(session, flowFile, signal, replaceOriginalAttributes);
session.transfer(flowFile, REL_EXPIRED);
return;