Repository: storm Updated Branches: refs/heads/1.0.x-branch 1a50bec2c -> 749208e70 refs/heads/1.x-branch 71476b48d -> 760f10aef refs/heads/master 02c4f6b40 -> a52e83b83
[STORM-1575] fix TwitterSampleSpout NPE on close Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a37ddbaa Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a37ddbaa Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a37ddbaa Branch: refs/heads/master Commit: a37ddbaa7a4c8b94a68efda94a74910333333820 Parents: dd00bc0 Author: manuzhang <[email protected]> Authored: Thu Feb 25 15:07:12 2016 +0800 Committer: manuzhang <[email protected]> Committed: Thu Feb 25 15:07:12 2016 +0800 ---------------------------------------------------------------------- .../apache/storm/starter/spout/TwitterSampleSpout.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/a37ddbaa/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); } }
