有没有办法覆盖Flink的/lib文件夹中的一些已发布函数?

lokaqttq  于 11个月前  发布在  Apache
关注(0)|答案(1)|浏览(101)

我的flink应用程序是通过yarn部署的,我在Flink的/lib文件夹中包含了所有必要的flink依赖。现在我想给jar 'flink-table-planner'添加一些独特的功能,但我不能直接修改lib文件夹中的jar,因为它是我所有合作伙伴使用的公共依赖。
我试图在jar中的yarn中的用户代码中覆盖它,但它会被/lib文件夹中的代码覆盖。
那么,有什么方法可以实现吗?如果你给予我一些提示,我将不胜感激!

zf2sa74q

zf2sa74q1#

我使用配置'classloader.parent-first-patterns.default'来覆盖默认值,但它不起作用,flink仍然使用'/lib'文件夹中的类,而不是我的类。

相关问题