我在运行数据流作业时遇到以下错误。我正在尝试将现有的 Beam 版本更新为 2.11.0,但在运行时出现以下错误。
java.lang.IncompleteClassChangeError:类 org.apache.beam.model.pipeline.v1.RunnerApi$StandardPTransforms$Primitives 未实现 org.apache.beam.runners.core.construction 处请求的接口 com.google.protobuf.ProtocolMessageEnum。 BeamUrns.getUrn(BeamUrns.java:27) 在 org.apache.beam.runners.core.construction.PTransformTranslation.(PTransformTranslation.java:58) 在 org.apache.beam.runners.core.construction.UnconsumedReads$1.visitValue( UnconsumedReads.java:49) 在 org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:666) 在 org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java: 649) 在 org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649) 在 org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649) 在 org .apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:311) 在 org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:245) 在 org.apache.beam。 sdk.Pipeline.traverseTopologically(Pipeline.java:458)在org.apache.beam.runners.core.construction.UnconsumedReads.ensureAllReadsConsumed(UnconsumedReads.java:40)在org.apache.beam.runners.dataflow.DataflowRunner.replaceTransforms( DataflowRunner.java:868) 在 org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:660) 在 org.apache.beam.runners.dataflow.DataflowRunner.run(DataflowRunner.java:173) 在 org .apache.beam.sdk.Pipeline.run(Pipeline.java:313) 在 org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)