пакет com.google.cloud.dataflow.sdk не найден

Question

Мой Dataflow Java код перестал компиляции/запуска при выполнении из Maven:

[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 

Answer 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> 

Это приводит к перерыву в версии 2.0 бета, где имена пакетов данных Google Dataflow были изменены на org.apache.beam.

В настоящем время, измените настройки 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, среди других изменений.