Hi all,

I am trying a sample beam job using flinkRunner.
*Beam-version -- 2.29.0*
*Flink server -- 1.12.7*
When running the job, I am getting below issue in the jobmanager logs

*Exception in thread "main" java.lang.NoSuchMethodError:
'org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever$Builder*
*org.apache.flink.client.deployment.application.ClassPathPackagedProgramRetriever.newBuilder(java.lang.String[],
org.apache.flink.configuration.Configuration)'*
*        at
org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.getPackagedProgramRetriever(StandaloneApplicationClusterEntryPoint.java:117)*
*        at
org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.getPackagedProgram(StandaloneApplicationClusterEntryPoint.java:103)*
*        at
org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.main(StandaloneApplicationClusterEntryPoint.java:69)*

Seems like the issue at classpath. I checked the compatibility matrix of
beam flink runner and in version 2.29.0, Flink 1.12.x is supported,

Please help me with the issue I am facing.

Thanks and Regards,
Sujay

Reply via email to