admin管理员组

文章数量:1530518

我的hadoop版本是3.1.3，Flink版本是1.14。不知道是hadoop版本的原因还是Flink版本更新的原因。当我运行一个简单的Flink测试时，虽然结果出来了但是后面还跟着一段报错信息。

测试命令：

flink run -m yarn-cluster -p 2 -yjm 2G -ytm 2G $FLINK_HOME/examples/batch/WordCount.jar

报错信息：

Trying to access closed classloader. Please check if you store classloaders directly or indirectly in static fields. If the stacktrace suggests that the leak occurs in a third party library and cannot be fixed immediately, you can disable this check with the configuration 'classloader.check-leaked-classloader'.

解决方法：

修改：flink/conf 的 flink-conf.yaml文件

添加：

classloader.check-leaked-classloader: false

注意：false前需要加上一个空格

本文标签： 报错leakedcheckclassloader

版权声明：本文标题：Flink1.14提交任务报错classloader.check-leaked-classloader问题解决 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://m.elefans.com/xitong/1725430000a1022800.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。