[STORM-1575] fix TwitterSampleSpout NPE on close Signed-off-by: P. Taylor Goetz <[email protected]>
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 <[email protected]> Authored: Thu Feb 25 15:07:12 2016 +0800 Committer: P. Taylor Goetz <[email protected]> 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); } }
