场景描述
采用 单作业模式提交作业后发现报错了
报错内容
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’. at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders
解决方式
flink-conf.yaml配置文件中增加如下设置
[hui@hadoop101 flink-1.17]$ vim conf/flink-conf.yaml classloader.check-leaked-classloader: false
再次提交作业正常了;
标签:lang,1.17,Exception,java,classloader,flink,conf,check From: https://www.cnblogs.com/wdh01/p/17690849.html