0
C'est la topologie de base de WordCount que j'ai essayé de lancer. Mais je reçois l'erreur comme 'INFO org.apache.storm.zookeeper.server.SessionTrackerImpl - SessionTrackerImpl a quitté la boucle!'. Est-ce que quelqu'un peut m'aider avec ça?? Lorsque j'ai supprimé cluster.shutdown(), les tweets arrivent continuellement jusqu'à ce que j'appuie sur cntrl + c. Encore une fois wordcount ne montre pasErreur lors de la soumission de la topologie de comptage de mots dans la tempête Apache
## import java.util.Arrays;
import backtype.storm.Config;
import backtype.storm.LocalCluster;
import backtype.storm.topology.TopologyBuilder;
import backtype.storm.tuple.Fields;
public class TwitterHashtagStorm {
public static void main(String[] args) throws Exception {
String consumerKey = "************";
String consumerSecret = "***************";
String accessToken = "**********";
String accessTokenSecret = "***********";
String[] keyWords = {"apple"};
Config config = new Config();
config.setDebug(true);
TopologyBuilder builder = new TopologyBuilder();
builder.setSpout("twitter-spout", new TwitterSampleSpout(consumerKey,
consumerSecret, accessToken, accessTokenSecret, keyWords));
builder.setBolt("twitter-hashtag-reader-bolt", new HashtagReaderBolt())
.shuffleGrouping("twitter-spout");
builder.setBolt("twitter-hashtag-counter-bolt",
new HashtagCounterBolt()).fieldsGrouping(
"twitter-hashtag-reader-bolt", new Fields("hashtag"));
LocalCluster cluster = new LocalCluster();
cluster.submitTopology("TwitterHashtagStorm", config,
builder.createTopology());
Thread.sleep(10000);
cluster.shutdown();
}
}