Hi Yogesh, Many of the examples, use the direct runner: https://github.com/apache/beam/tree/master/examples/java/src/main/java/org/apache/beam/examples
As does the word count example: https://beam.apache.org/get-started/quickstart-java/#get-the-wordcount-code I'm not well versed enough with our Java SDK (and dependencies for it), to recognize the error you shared. Good luck! Austin On Fri, Mar 20, 2020 at 9:25 AM Kumbhare, Yogesh <[email protected]> wrote: > 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) > > > > > > >
