NIFI-259 Updating logger message for AbstractListProcessor to reference State Manager in onTrigger instead of the distributed cache.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/16f18524 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/16f18524 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/16f18524 Branch: refs/heads/master Commit: 16f185245309ac3bcf9629b1c4d4dc655f18ca68 Parents: 29fb9c9 Author: Aldrin Piri <ald...@apache.org> Authored: Fri Feb 5 12:55:06 2016 -0500 Committer: Aldrin Piri <ald...@apache.org> Committed: Fri Feb 5 12:55:06 2016 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/AbstractListProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/16f18524/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractListProcessor.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractListProcessor.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractListProcessor.java index 53d0604..246f71a 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractListProcessor.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AbstractListProcessor.java @@ -345,7 +345,7 @@ public abstract class AbstractListProcessor<T extends ListableEntity> extends Ab justElectedPrimaryNode = false; } } catch (final IOException ioe) { - getLogger().error("Failed to retrieve timestamp of last listing from Distributed Cache Service. Will not perform listing until this is accomplished."); + getLogger().error("Failed to retrieve timestamp of last listing from the State Manager. Will not perform listing until this is accomplished."); context.yield(); return; }
