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
