FlinkSQL 动态加载 UDF 实现思路( 三 )

最后【FlinkSQL 动态加载 UDF 实现思路】以上就是在 Flink on K8S 集群 Session 模式下 ,FlinkSQL 动态加载 Jar 的解决方案 。 由于 REST API 没有提供 -C 效果 , 自定义 Jar URL 没有分发到 TaskMananger , 导致 TaskMananger 没有进行类加载到其 JVM 中 。 通过在 Job 的 main 方法中增加动态加载方法及配置 pipeline.classpaths , 可以达到不改动 Flink 源码的情况下实现 -C 效果 。 以上方案刚实现不久 , 还不保证是否有其他未知的问题 , 如果有更好的解决方案或者该方案中存在错误或者疏漏也欢迎提出共同讨论 。
感谢您的阅读 , 如果喜欢本文欢迎关注和转发 , 本头条号将坚持持续分享IT技术知识 。 对于文章内容有其他想法或意见建议等 , 欢迎提出共同讨论共同进步 。