指令信息文章来源:https://www.toymoban.com/news/detail-561922.html
.flink run -d -t yarn-per-job -c my.test.FlinkaStreamTest My-test-1.0-SNAPSHOT.jar
报错信息:Exception in thread “Thread-5” java.lang.IllegalStateException: 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’.
类加载器相关的报错,可能是类加载器问题
您可以使用配置“classloader.check-leaked-classloader”禁用此检查。
编辑flink-conf.yaml
增加 :classloader.check-leaked-classloader: false , 保存后重启任务即可文章来源地址https://www.toymoban.com/news/detail-561922.html
到了这里,关于flink 单作业模式部署提交作业爆:Trying to access closed classloader. Please check if you store classloaders direc的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!