langke93 发表于 2015-4-1 23:51
注释了确实没报错，不过eclipse却一直在运行计算中
那为什么加上最后一句就报错了么

这个有可能是zookeeper的原因

注释了确实没报错，不过eclipse却一直在运行计算中
那为什么加上最后一句就报错了么

不要 这句cluster.shutdown();

TopologyBuilder builder = new TopologyBuilder();

builder.setSpout("spout", new RandomSentenceSpout(), 5);

builder.setBolt("split", new SplitSentence(), 8).shuffleGrouping("spout");
builder.setBolt("count", new WordCount(), 12).fieldsGrouping("split",new Fields("word"));

Config conf = new Config();
conf.setDebug(true);

if (args != null && args.length > 0) {

conf.setNumWorkers(3);

StormSubmitter.submitTopology(args[0], conf,
builder.createTopology());
} else {
conf.setMaxTaskParallelism(3);

LocalCluster cluster = new LocalCluster();
cluster.submitTopology("word-count", conf, builder.createTopology());
Thread.sleep(10000);
cluster.shutdown();
}
  TopologyBuilder builder = new TopologyBuilder();
 
        builder.setSpout("spout", new RandomSentenceSpout(), 5);
 
        builder.setBolt("split", new SplitSentence(), 8).shuffleGrouping("spout");
        builder.setBolt("count", new WordCount(), 12).fieldsGrouping("split",new Fields("word"));
 
        Config conf = new Config();
        conf.setDebug(true);
 
        if (args != null && args.length > 0) {
            conf.setNumWorkers(3);
 
            StormSubmitter.submitTopology(args[0], conf,
                    builder.createTopology());
        } else {
            conf.setMaxTaskParallelism(3);
            LocalCluster cluster = new LocalCluster();
            cluster.submitTopology("word-count", conf, builder.createTopology());
            Thread.sleep(10000);
            cluster.shutdown();
        }
复制代码

arsenduan 发表于 2015-4-1 23:46
你在哪儿运行的？

直接在myeclipse下运行
WordCountTopology

你在哪儿运行的？