One thing that changed in Flink 1.4 with respect to Hadoop is that Hadoop is now an optional dependency. Since Hadoop dependencies are now dynamically loaded, you might use different versions on the client and the cluster?
Also the order in which classes are loaded changed. You could try to enable the previous classloading behavior by setting the parameter classloader.resolve-order: parent-first See the release notes [1] for details on Hadoop-free Flink and classloading changes. Hope this helps, Fabian [1] http://flink.apache.org/news/2017/12/12/release-1.4.0.html 2018-03-15 15:35 GMT+01:00 eSKa <eska...@gmail.com>: > we were jumping from version 1.3.1 (where everything worked fine) > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
