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
>
>
>
>&nbsp;

回复