I think , I got the answer ( application mode cluster doesn't support running
job using cli )
On Tuesday, October 5, 2021, 08:38:24 AM EDT, Israel Ekpo
wrote:
Your Flink versions are different
Your Docker container has version 1.13.2 but it seems your job is attempting to
submit with
Your Flink versions are different
Your Docker container has version 1.13.2 but it seems your job is
attempting to submit with 1.14 in application mode
That is the first obvious observation
On Tue, Oct 5, 2021 at 5:35 AM Dhiru wrote:
> *My DockerFile *
>
> FROM flink:1.13.2-scala_2.12-java11
>
My DockerFile
FROM flink:1.13.2-scala_2.12-java11
RUN mkdir -p /opt/flink/plugins/flink-s3-fs-hadoopRUN ln -fs
/opt/flink/opt/flink-s3-fs-hadoop-*.jar /opt/flink/plugins/flink-s3-fs-hadoop/.
RUN mkdir -p /opt/flink/plugins/flink-s3-fs-prestoRUN ln -fs
/opt/flink/opt/flink-s3-fs-presto-*.jar /opt