2017-12-09 14 views
0

私はapache beam missing classのための次のステップは?

PCollection<ReadableFile> activities = p.apply(
    "ReadBatchFiles", FileIO.match().filepattern("<google cloud storage bucket taken out>")) 
.apply(FileIO.readMatches()); 

のpom.xmlを実行しようとすると

java.lang.NoClassDefFoundError: org/apache/beam/runners/dataflow/util/DoFnInfo

apacheのビームを使用しようとすると、このエラーが発生します:

<dependencies> 
    <dependency> 
     <groupId>com.google.cloud.dataflow</groupId> 
     <artifactId>google-cloud-dataflow-java-sdk-all</artifactId> 
     <version>2.1.0</version> 
    </dependency> 
<dependency> 
    <groupId>org.apache.beam</groupId> 
    <artifactId>beam-sdks-java-core</artifactId> 
    <version>2.2.0</version> 
</dependency> 
<dependency> 
    <groupId>org.apache.beam</groupId> 
    <artifactId>beam-sdks-java-io-google-cloud-platform</artifactId> 
    <version>2.2.0</version> 
</dependency> 
<dependency> 
    <groupId>org.apache.beam</groupId> 
    <artifactId>beam-runners-direct-java</artifactId> 
    <version>2.2.0</version> 
    <scope>test</scope> 
</dependency> 
<dependency> 
    <groupId>org.apache.beam</groupId> 
    <artifactId>beam-runners-google-cloud-dataflow-java</artifactId> 
    <version>2.2.0</version> 
</dependency> 
<dependency> 

をこれがで移動させたように見えます: link1

おそらく:link2

どのように私は必要な場所にリンクしたいと思いますか?

おかげ

答えて

0

Googleはビーム2.2.0 only two days agoとDataflowJavaSDKを両立させるが、それはまだ発売されていません。 SDKのMavenリリース2.2.0を待つか、ソースからの依存関係を自分でコンパイルする必要があります。

関連する問題