Problem while implementing join in Apache Beam SQL

[Shakti Mishra]

Hi Team,

I am facing problem while performing join using Apache Beam SQL on two PCollection.

Whenever i am performing normal SQL its working fine but when i am performing any operation like join,union on two PCollection its throwing me below error while compilation:

 "An exception occured while executing the Java class. org.apache.beam.sdk.transforms.MapElements .via(Lorg/apache/beam/sdk/transforms/SimpleFunction;)Lorg/apache/beam/sdk/transforms/MapElements;"

Attaching the source code as well as pom.xml for the same.

Can anyone please help me to resolve this ?

Thanks in Advance !!

Regards,

Shakti Mishra

[José Valim]

Hi, this mailing list is about the Erlang VM (BEAM implementation) and not the Apache BEAM project. :)

José Valim

www.plataformatec.com.br

Skype: jv.ptec

Founder and Director of R&D

--
You received this message because you are subscribed to the Google Groups "BEAM Community" group.
To unsubscribe from this group and stop receiving emails from it, send an email to beam-communit...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/beam-community/21fe9550-7bf0-48e3-a79b-3547e3d9eb4a%40googlegroups.com.