Hi Team, Please find the below command to build .
mvn compile exec:java -Dexec.mainClass=com.intuit.dedupe.beam.poc.StreamingDedupe -Pdirect-runner is there any DirectRunner example you have please do share with us. Thanks , Yogesh K 8050397434 From: "Kumbhare, Yogesh" <[email protected]> Date: Friday, 20 March 2020 at 3:03 PM To: "[email protected]" <[email protected]> Subject: Issue in testing doing DirectRunner Apache Beam Local Machine 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)
