补充一种使用Flink api提交方式,参考:https://github.com/todd5167/flink-spark-submiter。

任务提交、状态获取继承统一的接口,上层服务在引用时,通过spi的方式进行加载即可。

缺点:
       - 需要对Flink client源码、类加载机制有了解。
优点:
       - 良好的外部集成
       - 不需要额外部署服务



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复