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 <vinay18.pa...@gmail.com> 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 >
