Exception in thread “main” java.lang.NoClassDefFoundError: org/apache/hadoop/yarn/exceptions/YarnException

执行flink on yarn_session时候,报错如下

Exception in thread “main” java.lang.NoClassDefFoundError: org/apache/hadoop/yarn/exceptions/YarnExc因为版本问题,flink没有提供flink-shaded-hadoop-*的jar包,需要自己手动添加。

在flink lib中加入flink-shaded-hadoop-2-uber-2.8.3-10.0 jar包。

有需要jar包可以留言。

添加后重启cluster,问题解决。

相关文章: