java.lang.NoClassDefFoundError: org/apache/beam/sdk/runners/PipelineRunner after migrating to dataflow 2.x

Question

出现运行时间错误：

"java.lang.NoClassDefFoundError: org/apache/beam/sdk/runners/PipelineRunner"

尽管我的 pom.xml

中有以下内容

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

移动到 2.X 后，所有编译时错误都已解决，开始出现运行时间错误。

mvn compile 在此项目上也报告成功。就在我尝试运行来自 eclipse 的管道时出现此错误。

Answer 1

我在下面添加了我的 pom.xml 并删除了 pom.xml 中的所有运行配置文件，错误已解决。

<dependency>
      <groupId>org.apache.beam</groupId>
      <artifactId>beam-runners-google-cloud-dataflow-java</artifactId>
      <version>[2.1.0, 2.99)</version>
    </dependency>

java.lang.NoClassDefFoundError: org/apache/beam/sdk/runners/PipelineRunner after migrating to dataflow 2.x

java.lang.NoClassDefFoundError: org/apache/beam/sdk/runners/PipelineRunner after migrating to dataflow 2.x

google-cloud-dataflow

apache-beam