客户端提交flink job 不能提交依赖的第三方jar,例如自定的函数jar,sql 里面的依赖connector jar,需要提前放置好。如果基于flink 平台化,需要动态的添加jar。目前可能的做法,就是把依赖的jar, 动态的添加作业jar 的lib目录下。getJobJarAndDependencies 就是从jar 中获取依赖的jar。不是很方便。 是可以添加一个参数,指定依赖的jar,flink 设计各种诡异。 [image: image.png]
- 提交任务不能指定第三方jar melin li
- Re: 提交任务不能指定第三方jar yuxia
- Re: 提交任务不能指定第三方jar melin li
- Re: 提交任务不能指定第三方jar melin li