Hello,
I'm trying to upgrade Flink from 1.7 to 1.10 retaining our Hadoop
integration. I copied the jar
file flink-shaded-hadoop-2-uber-2.7.5-10.0.jar into /opt/flink/lib. I also
copied the files flink-s3-fs-hadoop-1.10.0.jar and
flink-s3-fs-presto-1.10.0.jar into /opt/flink/plugins/s3 folder. T
Hello,
I upgraded Flink from 1.7 to 1.10 in Kubernetes. When the job manager is
launched, the following exception occurs. If I do some cleanup in
zookeeper and re-start, it will work. Any ideas about this error and what
needs to be done without having to do cleanup in zookeeper?
ERROR org.apac