场景描述
采用 单作业模式提交作业后发现报错了
报错内容
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
再次提交作业正常了;
- quot IllegalStateException 单词 Exception 版本quot illegalstateexception单词exception quot exception rabbitmq reason outofmemoryerror quot exception thread bindingexception quot exception statement messagingexception quot exception connect version unsupportedclassversionerror quot exception noclassdeffounderror quot serverfactory exception unsatisfiedlinkerror quot exception thread quot installation exception occurred noclassdeffounderror quot logfactory exception