0

を使用して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

C://directory/fileApache Beam は次のような構文を解析http://domain/fileすると思います -- それはCプロトコル名でdirectoryあり、ドメインであると考えます。C内部例外は、それが未知のプロトコルであると言っています。

://ローカル ファイルを参照する場合は、シンボルを使用しないようにしてください。通常の Windows 標準を使用することをお勧めします: C:\directory\file.

于 2016-10-27T17:05:30.913 に答える