在windows环境下用myeclipse构建了一个storm的demo，运行的时候报java.io.IOExcept...

about云腾讯认证空间

工程结构如下，我没有用maven来构建工程

高手们问个问题，刚接触storm，我在windows环境下用myeclipse构建了一个storm的demo，运行的时候报java.io.IOException: Unable to delete file: C:\Users\ADMINI~1\AppData\Local\Temp\d6ecd4c7-789c-4b56-a243-7ffcdf333f2b\version-2\log.1
      at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1390)
      at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1044)
      at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:977)
      at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1381)
      at org.apache.commons.io.FileUtils.cleanDirectory(FileUtils.java:1044)
      at org.apache.commons.io.FileUtils.deleteDirectory(FileUtils.java:977)
      at org.apache.commons.io.FileUtils.forceDelete(FileUtils.java:1381)
      at backtype.storm.util$rmr.invoke(util.clj:413)
      at backtype.storm.testing$kill_local_storm_cluster.invoke(testing.clj:163)
      at backtype.storm.LocalCluster$_shutdown.invoke(LocalCluster.clj:25)
      at backtype.storm.LocalCluster.shutdown(Unknown Source)
      at com.storm.WordCountTopology.main(WordCountTopology.java:91)
请问是怎么回事呢

arsenduan · 发表于 2015-4-1 23:46:19

你在哪儿运行的？

langke93 · 发表于 2015-4-1 23:47:25

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

直接在myeclipse下运行
WordCountTopology

langke93 · 发表于 2015-4-1 23:49:37

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();
        }
复制代码