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 2015/11/18 16:51:54 UTC
nifi git commit: NIFI-1176: Use a smaller internal blocking queue
size of only 5000 messages;
do not create a new queue every time the processor is scheduled to run
Repository: nifi
Updated Branches:
refs/heads/master 93be75330 -> 180ea1ba2
NIFI-1176: Use a smaller internal blocking queue size of only 5000 messages; do not create a new queue every time the processor is scheduled to run
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/180ea1ba
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/180ea1ba
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/180ea1ba
Branch: refs/heads/master
Commit: 180ea1ba222a5890541dfbe046f2876695e69239
Parents: 93be753
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Nov 16 15:50:14 2015 -0500
Committer: Aldrin Piri <al...@apache.org>
Committed: Wed Nov 18 10:51:22 2015 -0500
----------------------------------------------------------------------
.../main/java/org/apache/nifi/processors/twitter/GetTwitter.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/180ea1ba/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java
index e41b583..e099449 100644
--- a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java
+++ b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/main/java/org/apache/nifi/processors/twitter/GetTwitter.java
@@ -156,7 +156,7 @@ public class GetTwitter extends AbstractProcessor {
private final BlockingQueue<Event> eventQueue = new LinkedBlockingQueue<>(1000);
private volatile Client client;
- private volatile BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>(10000);
+ private volatile BlockingQueue<String> messageQueue = new LinkedBlockingQueue<>(5000);
@Override
protected void init(final ProcessorInitializationContext context) {
@@ -222,8 +222,6 @@ public class GetTwitter extends AbstractProcessor {
@OnScheduled
public void onScheduled(final ProcessContext context) throws MalformedURLException {
- messageQueue = new LinkedBlockingQueue<>(100000);
-
final String endpointName = context.getProperty(ENDPOINT).getValue();
final Authentication oauth = new OAuth1(context.getProperty(CONSUMER_KEY).getValue(),
context.getProperty(CONSUMER_SECRET).getValue(),