报错:you can disable this check with the configuration 'classloader.check-leaked-classloader'.

提问者:帅平 问题分类:大数据
使用Dolphinscheduler 运行flink job的时候,我们能看到执行成功,但是在最后会报错:
Exception in thread "Thread-4" 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.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:184)
		at org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.getResource(FlinkUserCodeClassLoaders.java:208)
		at org.apache.hadoop.conf.Configuration.getResource(Configuration.java:2839)
		at org.apache.hadoop.conf.Configuration.getStreamReader(Configuration.java:3113)
		at org.apache.hadoop.conf.Configuration.loadResource(Configuration.java:3072)
		at org.apache.hadoop.conf.Configuration.loadResources(Configuration.java:3045)
		at org.apache.hadoop.conf.Configuration.loadProps(Configuration.java:2923)
		at org.apache.hadoop.conf.Configuration.getProps(Configuration.java:2905)
		at org.apache.hadoop.conf.Configuration.get(Configuration.java:1247)
		at org.apache.hadoop.conf.Configuration.getTimeDuration(Configuration.java:1864)
		at org.apache.hadoop.conf.Configuration.getTimeDuration(Configuration.java:1841)
		at org.apache.hadoop.util.ShutdownHookManager.getShutdownTimeout(ShutdownHookManager.java:183)
		at org.apache.hadoop.util.ShutdownHookManager.shutdownExecutor(ShutdownHookManager.java:145)
		at org.apache.hadoop.util.ShutdownHookManager.access0(ShutdownHookManager.java:65)
		at org.apache.hadoop.util.ShutdownHookManager.run(ShutdownHookManager.java:102)

如下图:
报错:you can disable this check with the configuration 'classloader.check-leaked-classloader'.
请问这个怎么配置?
1 个回答
温柔刀下鬼
温柔刀下鬼
在原始的flink集群里面,配置下${flink_home}/conf/flink-conf.yaml文件,添加上如下配置即可:
classloader.check-leaked-classloader: false
发布于:10个月前 (04-19) IP属地:四川省
我来回答