flink 单作业模式部署提交作业爆:Trying to access closed classloader. Please check if you store classloaders direc
报错信息:Exception in thread "Thread-5" java.lang.IllegalStateException: Trying to access closed classloader. Please check增加 :classloader.check-leaked-classloader: false , 保存后重启任务即可。您可以使用配置“classloader.ch
指令信息
.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 , 保存后重启任务即可
魔乐社区(Modelers.cn) 是一个中立、公益的人工智能社区,提供人工智能工具、模型、数据的托管、展示与应用协同服务,为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作,由全产业链共同建设、共同运营、共同享有,推动国产AI生态繁荣发展。
更多推荐

所有评论(0)