Я получаю ошибку ниже при выполнении задания потока данных. Я пытаюсь обновить свою существующую версию луча до 2.11.0, но я получаю ошибку ниже во время выполнения.
java.lang.IncompatibleClassChangeError: Class
org.apache.beam.model.pipeline.v1.RunnerApi $ StandardPTransforms $ Примитивы
не реализует запрошенный интерфейс
com.google.protobuf.ProtocolMessageEnum в
org.apache.beam.runners.core.construction.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)