我的hadoop版本是3.1.3，F(xiàn)link版本是1.14。不知道是hadoop版本的原因還是Flink版本更新的原因。當(dāng)我運(yùn)行一個(gè)簡單的Flink測試時(shí)，雖然結(jié)果出來了但是后面還跟著一段報(bào)錯(cuò)信息。
測試命令：
flink run -m yarn-cluster -p 2 -yjm 2G -ytm 2G $FLINK_HOME/examples/batch/WordCount.jar
報(bào)錯(cuò)信息：
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文章來源：http://www.zghlxwxcb.cn/news/detail-505055.html
注意：false前需要加上一個(gè)空格文章來源地址http://www.zghlxwxcb.cn/news/detail-505055.html
到了這里，關(guān)于Flink1.14提交任務(wù)報(bào)錯(cuò)classloader.check-leaked-classloader問題解決的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！
