关于配置参数的问题
执行代码时,报了如下错误
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
大数据工程师 2024 版
- 参与学习 1151 人
- 提交作业 5960 份
- 解答问题 1144 个
不用Java初级内容充数!不用与大数据岗位无关内容占课时!我们做的就是“精华版”大数据课程
了解课程
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星