In Flink 1.11, there were some changes how the Flink clients dependency is
bundled in [1]. The error you're seeing is likely due to the flink-clients
module not being on the classpath anymore. Can you check your dependencies
and update the pom.xml as suggested in [1]?
Matthias
[1] https://flink.a
As you suggested I downloaded flink 1.11.3
to submit a flink job . The actual application is developed in flink 1.8.1.
Since the Hadoop cluster is 3.2.0 apache I downloaded flink 1.11.3 (
flink-1.11.3-bin-scala_2.11.tgz) and tried to submit the job.
while submitting facing the below mentioned e
Thank you for the clarification.
On Mon, May 3, 2021 at 6:57 PM Matthias Pohl wrote:
> Hi Ragini,
> this is a dependency version issue. Flink 1.8.x does not support Hadoop 3,
> yet. The support for Apache Hadoop 3.x was added in Flink 1.11 [1] through
> FLINK-11086 [2]. You would need to upgrade
Hi Ragini,
this is a dependency version issue. Flink 1.8.x does not support Hadoop 3,
yet. The support for Apache Hadoop 3.x was added in Flink 1.11 [1] through
FLINK-11086 [2]. You would need to upgrade to a more recent Flink version.
Best,
Matthias
[1]
https://flink.apache.org/news/2020/07/06/r
