在Apache storm中提交字数拓扑时出错

Question

这是我尝试运行的基本wordcount拓扑。但我收到的错误是“信息组织”。阿帕奇。暴风雨动物园管理员。服务器SessionTrackerImpl-SessionTrackerImpl已退出循环！'。有人能帮我吗？？

当我移除集群时。shutdown（），在我按下cntrl c之前，tweets会一直出现。wordcount也不会显示##

     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();
}
}

Answer 1

10秒（10000毫秒）可能不足以建立推特连接，也不足以让推特进入您的拓扑结构。您应该将睡眠呼叫设置为更长的时间（至少几分钟）。

至于显示工作计数，HashTagCounter是否将计数打印出来？如果是这样，打印输出可能会丢失在Storm的日志消息中。尝试设置config。setDebud（false）（减少日志消息并让您有机会看到计数）或重写HashTagCounter以将消息发送到与您运行Storm的控制台分离的另一个位置（消息代理、本地套接字接收器等）。