You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/06/09 20:54:07 UTC
[26/35] storm git commit: [STORM-1575] fix TwitterSampleSpout NPE on
close
[STORM-1575] fix TwitterSampleSpout NPE on close
Signed-off-by: P. Taylor Goetz <pt...@gmail.com>
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/12ba18b8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/12ba18b8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/12ba18b8
Branch: refs/heads/1.x-branch
Commit: 12ba18b820723e57e6c18b7d874a4e206c1ccd54
Parents: 135d7cd
Author: manuzhang <ow...@gmail.com>
Authored: Thu Feb 25 15:07:12 2016 +0800
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Thu Jun 9 16:43:22 2016 -0400
----------------------------------------------------------------------
.../apache/storm/starter/spout/TwitterSampleSpout.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/12ba18b8/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java b/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java
index df26d25..e8a2c05 100644
--- a/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java
+++ b/examples/storm-starter/src/jvm/org/apache/storm/starter/spout/TwitterSampleSpout.java
@@ -103,24 +103,24 @@ public class TwitterSampleSpout extends BaseRichSpout {
};
- TwitterStream twitterStream = new TwitterStreamFactory(
+ _twitterStream = new TwitterStreamFactory(
new ConfigurationBuilder().setJSONStoreEnabled(true).build())
.getInstance();
- twitterStream.addListener(listener);
- twitterStream.setOAuthConsumer(consumerKey, consumerSecret);
+ _twitterStream.addListener(listener);
+ _twitterStream.setOAuthConsumer(consumerKey, consumerSecret);
AccessToken token = new AccessToken(accessToken, accessTokenSecret);
- twitterStream.setOAuthAccessToken(token);
+ _twitterStream.setOAuthAccessToken(token);
if (keyWords.length == 0) {
- twitterStream.sample();
+ _twitterStream.sample();
}
else {
FilterQuery query = new FilterQuery().track(keyWords);
- twitterStream.filter(query);
+ _twitterStream.filter(query);
}
}