关于配置参数的问题
执行代码时,报了如下错误
Exception in thread "Thread-8" 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'.
我在代码中进行了如下配置,但是似乎没有生效,是配置的方式有问题吗?因为执行代码后,依然出现上述错误
6
收起
正在回答
1回答
在客户端节点中进行修改,修改 flink 的 conf 目录下的flink-conf.xml配置文件,添加下面配置试一下,需要通过客户端提交任务到集群进行验证。
classloader.check-leaked-classloader: false
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星