Thank you Juan, adding the following worked for me: transformer implementation= "org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"
Regards, Vinay Patil On Mon, Dec 3, 2018 at 11:21 PM Juan Carlos Garcia <[email protected]> wrote: > Hi Vinay, > > When generating your Fatjar make sure you are merging the service files > (META-INF/services) of your dependencies. > > Apache Beam relies heavily on the Java service locator to discover / > register its components. > > JC > > > Am Di., 4. Dez. 2018, 03:18 hat Vinay Patil <[email protected]> > geschrieben: > >> Hi, >> >> I am using Beam 2.8.0 version. When I submit pipeline to Flink 1.5.2 >> cluster, I am getting the following exception: >> >> Caused by: java.lang.IllegalStateException: No translator known for >> org.apache.beam.sdk.io.Read$Bounded >> >> Can you please let me know what could be the problem? >> >> Regards, >> Vinay Patil >> >
