Exception in thread “Thread-3” 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.FlinkUserCodeClassLoadersSafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:164)atorg.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoadersSafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:164) at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoadersSafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:164)atorg.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoadersSafetyNetWrapperClassLoader.getResource(FlinkUserCodeClassLoaders.java:183)

解决办法： 在 flink 配置文件里 flink-conf.yaml设置
classloader.check-leaked-classloader: false