flink jar 部署

Question

springboot 的flink 程序jar 能在集群上执行吗

Answer 1

Michael_PK 2022-12-20 18:47:25

没这么用过，不清楚。

boot和flink整合的意义在哪？

• 慕斯卡0991186 #1

  我也用了n多的方法，也没整合成功，所以拟定是放弃boot整合flink了，毕竟flink流中是不允许使用非静态的，而boot很多对象属性都是非静态的。如果需要消费数据，直接cdc到kafka去，而消费的应用就可以使用boot通过kafka来承接了。这样使用较为稳妥。所以flink的意义，在于实时获取数据并进行etl，而且相关的数据库操作都已经帮你封装好了，如果非要使用Mybatis，那就用原生那套自己封装一下就可以了。

• Michael_PK 回复 慕斯卡0991186 #2

  我在工作中，几乎没用整合boot使用过，因为你的flink作业启动之后就是一个long service的服务，该处理的业务都在flink中完成就行了，如果带代码中你要去调用boot提供出来的服务，那只需要httpclient发送请求过去就可以了。如果你要操作数据库，那还是在flink代码中去调用对应的工具类就可以了，并不一定想要使用mybatis之类的，当然也有一个操作，你在flink中调用微服务，在微服务中你可以使用类似mybatis等ormapping框架

• 慕斯卡0991186 回复 Michael_PK #3

  嗯，挺好的，方向一致，那以后工作中就这么用。