java - 错误 backtype.storm.util - 异步循环终止

Question

我绝对是 Storm 新手。这是 Storm 入门(书籍)中的一个示例。单词计数器示例。我在本地使用 Storm，当我使用 Maven 运行这个示例时，我收到此错误。Maven命令使用:

[knk@kinock Storm-Starter]$mvn exec:java -Dexec.mainClass="TopologyMain" -Dexec.args="src/main/resources/words.txt"

这是错误

java.lang.NullPointerException: null
at spouts.WordReader.open(WordReader.java:62) ~[classes/:na]
at backtype.storm.daemon.executor$fn__3430$fn__3445.invoke(executor.clj:504) ~[storm-core-0.9.0.1.jar:na]
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:401) ~[storm-core-0.9.0.1.jar:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_45]
5608 [Thread-22-word-reader] ERROR backtype.storm.daemon.executor - 
java.lang.NullPointerException: null
at spouts.WordReader.open(WordReader.java:62) ~[classes/:na]
at backtype.storm.daemon.executor$fn__3430$fn__3445.invoke(executor.clj:504) ~  [storm-core-0.9.0.1.jar:na]
at backtype.storm.util$async_loop$fn__444.invoke(util.clj:401) ~[storm-core- 0.9.0.1.jar:na]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.4.0.jar:na]
at java.lang.Thread.run(Thread.java:744) [na:1.7.0_45]
5610 [Thread-6] INFO  backtype.storm.daemon.executor - Loading executor __system:[-1 -1]
5618 [Thread-6] INFO  backtype.storm.daemon.task - Emitting: __system __system  ["startup"]
5619 [Thread-6] INFO  backtype.storm.daemon.executor - Loaded executor tasks __system: [-1 -1]
5624 [Thread-6] INFO  backtype.storm.daemon.executor - Finished loading executor __system:[-1 -1]
5629 [Thread-24-__system] INFO  backtype.storm.daemon.executor - Preparing bolt __system:(-1)
5638 [Thread-24-__system] INFO  backtype.storm.daemon.executor - Prepared bolt __system:(-1)
5668 [Thread-6] INFO  backtype.storm.daemon.executor - Loading executor __acker:[1 1]
5670 [Thread-6] INFO  backtype.storm.daemon.task - Emitting: __acker __system ["startup"]
5671 [Thread-6] INFO  backtype.storm.daemon.executor - Loaded executor tasks __acker:[1 1]
5672 [Thread-22-word-reader] INFO  backtype.storm.util - Halting process: ("Worker died")
5678 [Thread-6] INFO  backtype.storm.daemon.executor - Timeouts disabled for executor __acker:[1 1]
5679 [Thread-6] INFO  backtype.storm.daemon.executor - Finished loading executor __acker: [1 1]

这是引发异常的代码块..第 62 行标有注释。

public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
        try {

            //this.collector = collector;
            this.context = context;
            this.fileReader = new  FileReader(conf.get("wordsFile").toString());//exception is raised here. 62nd line
        } catch (FileNotFoundException e){
            throw new RuntimeException("Error reading file ["+conf.get("wordFile")+"]");
            }
        this.collector = collector;
    }

提前致谢..

Answer 1

[knk@kinock Storm-Starter]$mvn exec:java -Dexec.mainClass="TopologyMain"-Dexec.args="src/main/resources/words.txt"

在上面的命令中应该给出文件的完整路径，否则java无法找到该路径。