I have reviewed all those issues, I do not think it is the same issue. I believe this has something to do with unbounded streams and kinesisIO. I've tried the 1.18 flink runner as well. I'm creating an issue. thanks
On Fri, Dec 5, 2025 at 10:48 PM Yu Watanabe <[email protected]> wrote: > Hello Alek. > > Just looking at your error it looks very similar to these cases. > > > https://stackoverflow.com/questions/54131037/no-translator-error-while-running-apache-beam-job-on-flink-cluster#:~:text=I%20think%20the%20key%20error,an%20answer%20to%20Stack%20Overflow > ! > https://lists.apache.org/thread/891m8ro4v4tgfzd73gznlzcrnqh47kb4 > > Perhaps missing any dependencies in your build tool ? > Below is a sample when using maven. > > > https://docs.aws.amazon.com/managed-flink/latest/java/examples-beam.html#examples-beam-download > > https://github.com/aws-samples/amazon-kinesis-data-analytics-examples/blob/master/Beam/pom.xml > > Thanks, > Yu > > On Sat, Dec 6, 2025 at 5:40 AM Alek Mitrevski <[email protected]> > wrote: > >> Hi, hopefully someone can shed some light on this. I have a managed flink >> job in AWS using Flink 1.19, and Beam 2.69.0. I am having >> difficulty troubleshooting this issue, and I am wondering if this is an >> incompatibility. >> >> Any information on this would be greatly appreciated. >> >> Thanks, >> Alek >> >> Caused by: org.apache.flink.client.program.ProgramInvocationException: The >> main method caused an error: No translator known for >> org.apache.beam.sdk.util.construction.SplittableParDo$PrimitiveUnboundedRead >> >> >> > > -- > Yu Watanabe > > linkedin: www.linkedin.com/in/yuwatanabe1/ > twitter: twitter.com/yuwtennis > >
