Hi Team ,
I am facing issue to run the simple project on Direct Runner Apache beam , to
test the example locally in our machine .
I added in pom.xml dependency ,
<dependency>
<groupId>org.apache.beam</groupId>
<artifactId>beam-runners-direct-java</artifactId>
<version>2.19.0</version>
<scope>runtime</scope>
</dependency>
Please find the below error , let me know any update .
Exception in thread "main" java.lang.IncompatibleClassChangeError: Class
org.apache.beam.model.pipeline.v1.RunnerApi$StandardPTransforms$Primitives does
not implement the requested interface
org.apache.beam.vendor.grpc.v1p21p0.com.google.protobuf.ProtocolMessageEnum
at
org.apache.beam.repackaged.direct_java.runners.core.construction.BeamUrns.getUrn(BeamUrns.java:27)
at
org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformTranslation.<clinit>(PTransformTranslation.java:129)
at
org.apache.beam.repackaged.direct_java.runners.core.construction.PTransformMatchers.lambda$writeWithRunnerDeterminedSharding$1(PTransformMatchers.java:483)
at
org.apache.beam.sdk.Pipeline$2.enterCompositeTransform(Pipeline.java:268)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:645)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.visit(TransformHierarchy.java:649)
at
org.apache.beam.sdk.runners.TransformHierarchy$Node.access$600(TransformHierarchy.java:311)
at
org.apache.beam.sdk.runners.TransformHierarchy.visit(TransformHierarchy.java:245)
at
org.apache.beam.sdk.Pipeline.traverseTopologically(Pipeline.java:458)
at org.apache.beam.sdk.Pipeline.replace(Pipeline.java:258)
at org.apache.beam.sdk.Pipeline.replaceAll(Pipeline.java:208)
at
org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:170)
at
org.apache.beam.runners.direct.DirectRunner.run(DirectRunner.java:67)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:313)
at org.apache.beam.sdk.Pipeline.run(Pipeline.java:299)
at
com.intuit.dedupe.beam.poc.StreamingDedupe.main(StreamingDedupe.java:144)
