Hi, 我考虑过的几种方式: 1. 做成http服务,和flink分离,py模型本来跑起来也不快,做成http可以动态扩容,无状态的话 2. 用pyflink来跑任务,可以嵌python代码,就是任务启动非常慢,要复制虚拟环境,模型可以写成pandas的输入输出,这样模型也是可以独立开发的 3. Java调python的udf,py必须要能封装成函数,写udf毕竟麻烦
Thanks 在 2022-12-19 16:51:33,"kcz" <573693...@qq.com.INVALID> 写道: >flink调用py模型时候,大是采取什么方案,直接跟flink集成嘛? 还是py模型做成web服务。 >如果是web服务的话,是不是会出现无法支撑flink的大量调用呢? > > >kcz >573693...@qq.com > > > >