关于配置参数的问题

关于配置参数的问题

执行代码时,报了如下错误

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'.

我在代码中进行了如下配置,但是似乎没有生效,是配置的方式有问题吗?因为执行代码后,依然出现上述错误

https://img1.sycdn.imooc.com/climg/6592521c09943f3214540209.jpg





正在回答

登陆购买课程后可参与讨论,去登陆

1回答

在客户端节点中进行修改,修改 flink 的 conf 目录下的flink-conf.xml配置文件,添加下面配置试一下,需要通过客户端提交任务到集群进行验证。

classloader.check-leaked-classloader: false

  • 蒋昌魁 提问者 #1

    嗯,老师这个我修改了,集群上修改配置文件后在集群上运行没问题。尝试了下在代码中修改,希望本地也不报错,感觉方式应该是这样的,看源码好像类似这样,不过尝试很多种方案后在代码中修改的方式都不奏效,我有怀疑可能是flink里的bug,无法通过代码修改自定义的配置,不过也怀疑是自己的问题,所以想跟您求证下是我的方式的问题还是flink里的bug

    2024-01-01 19:27:57
  • 徐老师 回复 提问者 蒋昌魁 #2

    这种问题可能是flink的bug,因为flink版本迭代的比较快,一些细节方面做的不是特别完善。

    2024-01-02 10:37:00
问题已解决,确定采纳
还有疑问,暂不采纳

恭喜解决一个难题,获得1积分~

来为老师/同学的回答评分吧

0 星

相似问题

登录后可查看更多问答,登录/注册

请稍等 ...
意见反馈 帮助中心 APP下载
官方微信

在线咨询

领取优惠

免费试听

领取大纲

扫描二维码,添加
你的专属老师