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

回复