1

Maven から実行すると、Dataflow Java コードがコンパイル/実行を停止しました:

[ERROR] symbol:   class Pipeline
[ERROR] location: package com.google.cloud.dataflow.sdk
[ERROR] ... package com.google.cloud.dataflow.sdk.io does not exist
[ERROR] ... package com.google.cloud.dataflow.sdk.options does not exist
[ERROR] ... package com.google.cloud.dataflow.sdk.transforms does not exist
4

1 に答える 1

1

pom.xml には、次のような行が含まれている可能性があります。

<dependency>
  <groupId>com.google.cloud.dataflow</groupId>
  <artifactId>google-cloud-dataflow-java-sdk-all</artifactId>
  <version>[1.6.0, 2.0.0)</version>
</dependency>

これにより、Google Dataflow パッケージ名が org.apache.beam に変更された 2.0-beta への重大な変更が取り込まれます。

とりあえず、pom.xml 設定を次のように変更します。

<dependency>
  <groupId>com.google.cloud.dataflow</groupId>
  <artifactId>google-cloud-dataflow-java-sdk-all</artifactId>
  <version>[1.6.0, 1.9.9)</version>
</dependency>

準備ができたら、次の手順に従います。

https://cloud.google.com/dataflow/release-notes/release-notes-java-2

Java コードを更新します。パッケージ名を変更するだけではありません。ランナー名が変更され、DoFns には @ProcessElement アノテーションなどが必要になります。

于 2017-01-10T17:40:06.763 に答える