我换了班 WordCount 在 WordCountTopology 具体如下：

public static class WordCount extends BaseBasicBolt {
    Map<String, Integer> counts = new HashMap<String, Integer>();

    @Override
    public void execute(Tuple tuple, BasicOutputCollector collector) {
        String word = tuple.getString(0);
        Integer count = counts.get(word);
        if(count==null) count = 0;
        count++;
        counts.put(word, count);
        OutputStream o;
        try {
            o = new FileOutputStream("~/abc.txt", true);
            o.write(word.getBytes());
            o.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        collector.emit(new Values(word, count));
    }

    @Override
    public void declareOutputFields(OutputFieldsDeclarer declarer) {
        declarer.declare(new Fields("word", "count"));
    }
}

我把单词写进文件里 .txt .
当我运行 WordCountTopology 在本地模式下（使用 LocalCluster )，效果不错。但是在分布式模式下运行时（使用 StormSubmitter.submitTopology() 方法） WordCount 班上没有写这个词 .txt 好像 execute() 方法根本没有运行。谁能给我一些建议吗？谢谢！
p、 我确信我的nimbus，supervisor，ui，zookeeper运行正常，我可以在127.0.0.1:8080中看到这个任务。