Repository: nifi Updated Branches: refs/heads/develop d328ca0a4 -> c2c513e51
NIFI-837 Signed-off-by: Mark Payne <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/c2c513e5 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/c2c513e5 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/c2c513e5 Branch: refs/heads/develop Commit: c2c513e51122bf09d0f7cb717a59272c305341d6 Parents: d328ca0 Author: Mike Moser <[email protected]> Authored: Mon Aug 10 20:31:17 2015 -0400 Committer: Mark Payne <[email protected]> Committed: Tue Aug 11 08:55:04 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/GetFileTransfer.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/c2c513e5/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GetFileTransfer.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GetFileTransfer.java b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GetFileTransfer.java index 0b06244..810a91e 100644 --- a/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GetFileTransfer.java +++ b/nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GetFileTransfer.java @@ -114,7 +114,7 @@ public abstract class GetFileTransfer extends AbstractProcessor { public void onTrigger(final ProcessContext context, final ProcessSession session) { final long pollingIntervalMillis = context.getProperty(FileTransfer.POLLING_INTERVAL).asTimePeriod(TimeUnit.MILLISECONDS); final long nextPollTime = lastPollTime.get() + pollingIntervalMillis; - final BlockingQueue<FileInfo> fileQueue = fileQueueRef.get(); + BlockingQueue<FileInfo> fileQueue = fileQueueRef.get(); final ProcessorLog logger = getLogger(); // dont do the listing if there are already 100 or more items in our queue @@ -143,6 +143,7 @@ public abstract class GetFileTransfer extends AbstractProcessor { } } + fileQueue = fileQueueRef.get(); if (fileQueue == null || fileQueue.isEmpty()) { // nothing to do! context.yield();
