Error incompatible types for field cpuCores when doing Flink Upgrade

2020-06-11 Thread Claude Murad
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

NoSuchMethodError: org.apache.flink.fs.s3.common.AbstractS3FileSystemFactory.(Ljava/lang/String;Lorg/apache/flink/fs/s3presto/common/HadoopConfigLoader

2020-06-09 Thread Claude Murad
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.