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
