0

使用 Eclipse 在 Eclipse 中下载 maven 依赖项

<dependency>
<groupId>org.apache.beam</groupId>
<artifactId>beam-runners-direct-java</artifactId>
<version>0.2.0-incubating</version></dependency>

在将 gs 路径更改为 C://examples//misc.txt 后下载并运行 WordCount示例时。获取以下异常。我没有传递任何跑步者。如何在从 Eclipse 运行时传递跑步者选项和输出参数？ ?

    SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
Exception in thread "main" java.lang.IllegalStateException: Failed to validate C://examples//misc.txt
    at org.apache.beam.sdk.io.TextIO$Read$Bound.apply(TextIO.java:288)
    at org.apache.beam.sdk.io.TextIO$Read$Bound.apply(TextIO.java:195)
    at org.apache.beam.sdk.runners.PipelineRunner.apply(PipelineRunner.java:76)
    at org.apache.beam.runners.direct.DirectRunner.apply(DirectRunner.java:205)
    at org.apache.beam.sdk.Pipeline.applyInternal(Pipeline.java:401)
    at org.apache.beam.sdk.Pipeline.applyTransform(Pipeline.java:324)
    at org.apache.beam.sdk.values.PBegin.apply(PBegin.java:59)
    at org.apache.beam.sdk.Pipeline.apply(Pipeline.java:174)
    at org.apache.beam.examples.WordCount.main(WordCount.java:206)
Caused by: java.io.IOException: Unable to find handler for C://examples//misc.txt
    at org.apache.beam.sdk.util.IOChannelUtils.getFactory(IOChannelUtils.java:188)
    at org.apache.beam.sdk.io.TextIO$Read$Bound.apply(TextIO.java:283)
    ... 8 more
4

1 回答 1

0

我相信 Apache Beam 会解析C://directory/file类似的语法http://domain/file——它会认为那C是一个协议名称，那directory是一个域。内部异常是说这C是一个未知的协议。

://引用本地文件时请尽量避免使用符号。我建议使用常规的 Windows 标准：C:\directory\file.

于 2016-10-27T17:05:30.913 回答