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技术知识 。 对于文章内容有其他想法或意见建议等 , 欢迎提出共同讨论共同进步 。
- Windows11|Windows 11 操作系统已经完全取消了 Windows 8 时代的动态磁贴
- 7nm|支持8K/120Hz动态补帧!联发科发布首款7nm电视芯片
- 耳机|Xiaomi真无线降噪耳机3Pro,动态降噪,静听曼妙
- 索尼|索尼A7M4测试:高像素高解析力,动态范围妥协
- 人工智能|IEEE Fellow姚新:在多目标动态优化问题中,演化计算仍有独特优势
- 达晨财智|融资丨「世通亨奇」获达晨财智领投近亿元A轮融资,采用动态本体技术分析数据信息
- 按钮|Axure9 打开同一个页面时显示页面中不同的动态面板
- 豆瓣|从圈子到话题,从帖子到动态,表达更自由,互动更稀缺
- 造车|百度造车最新进展:集度模拟样车已进入动态测试阶段
- 百度|百度造车最新进展:集度模拟样车已进入动态测试阶段