Beam está utilizando tanto Googleauto / valor yauto servicio herramientas.

Quiero ejecutar una tubería con Dataflow Runner y los datos se almacenan en Google Cloud Storage.

He agregado unas dependencias:

<dependency>
    <groupId>org.apache.beam</groupId>
    <artifactId>beam-runners-google-cloud-dataflow-java</artifactId>
    <version>2.0.0</version>
</dependency>

<dependency>
    <groupId>org.apache.beam</groupId>
    <artifactId>beam-sdks-java-extensions-google-cloud-platform-core</artifactId>
    <version>2.0.0</version>
</dependency>

Puedo comenzar la tubería desde el IntelliJ. Pero cuando el frasco se compila a través de unmvn package y correr conjava -jar arroja un error:

java.lang.IllegalStateException: Unable to find registrar for gs

El fatjar es paquete conmaven-assembly-plugin. GcsFileSystemRegistrar La clase está en el frasco.