1

我正在编译 maven 项目以在 linux 机器上运行 Storm Topology。

以下是 Bolt 类中的一个方法，这里我想在运行时创建一个文件，其中缓冲的 Reader 将从输入中收集数据并将其写入文件。

元组输入对象：包含要写入的数据。
/root/data/javacode/top_output.csv：文件名。
所有 IO 包都已在代码中导入。

public void execute(Tuple input, BasicOutputCollector collector) {
    String sentence = input.getString(0);
    String[] process = sentence.split(" ");
    File file = new File("/root/data/jcode/top_output.csv");
    if (!file.exists()) {
        file.createNewFile();
    }
    FileWriter fw = new FileWriter(file.getAbsoluteFile());  // line no. 36
    BufferedWriter bw = new BufferedWriter(fw);  
    for (String proc : process) {
        proc = proc.trim();
        if (!proc.isEmpty()) {
            collector.emit(new Values(proc));
            bw.write(proc);    // line no. 42
        }
    }
    bw.close();
}

每当我使用mvn package编译项目时，都会出现编译错误：

[INFO] --- maven-compiler-plugin:2.3.2:compile (default-compile) @ lgassStorm ---
[WARNING] File encoding has not been set, using platform encoding UTF-8, i.e. build is platform dependent!
[INFO] Compiling 4 source files to /root/data/lgassStorm/target/classes
[INFO] -------------------------------------------------------------
[ERROR] COMPILATION ERROR :
[INFO] -------------------------------------------------------------
[ERROR] /root/data/lgassStorm/src/main/java/lgaas/bolts/DataNormalizer.java:[36,19] error: unreported exception IOException; must be caught or declared to be thrown
[ERROR] /root/data/lgassStorm/src/main/java/lgaas/bolts/DataNormalizer.java:[42,13] error: unreported exception IOException; must be caught or declared to be thrown
[INFO] 2 errors

每当我评论 Filewriter 相关代码时，它都会成功运行。上面的代码中提到了行号。代码有什么问题？

4

2 回答 2

0

您需要指定函数执行会引发 IOException。

public void execute(Tuple input, BasicOutputCollector collector) throws IOException {

或者您可以捕获异常。这是为了防止其中一个 IO 操作失败。

于 2013-03-06T11:01:41.433 回答
0

尝试抛出 IOException 或将您的代码包围到 TryCatch 块。

public void execute(Tuple input, BasicOutputCollector collector){
try{
your code...
}catch (IOException e){
e.printStackTrace ();
}
}
于 2013-03-06T11:12:34.780 回答