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
