您好！
看起来这个问题与 FLINK-35066[1] 有关，该问题描述了在 IterationBody 内实现自定义的RichCoProcessFunction 或
CoFlatMapFunction 算子时遇到的拆包问题，可以追溯到这个[2]邮件列表中的问题报告。看起来这个问题也同样影响您使用的
RichCoMapFunction 算子。
该问题已被此 Pull Request[3] 解决，并已合入 master 主分支。按照文档[4]尝试在本地编译 2.4-SNAPSHOT
快照版本并执行您的代码，看起来能够正常工作。
鉴于这是一个 Flink ML 2.3 版本中的已知问题
这个取决于你是什么模型，比如python中sklearn的大多模型都可以导出成pmml格式模型，然后java用jpmml库就可以导入进行预测。
如果是tensorflow模型，也有，只不过我忘记了，你可以找找。
15904502343 <15904502...@163.com> 于2023年8月1日周二 16:48写道：
>
> 您好
> 我想知道是否有代码示例，可以在Flink程序中加载预先训练好的编码模型(用python编写)
您好
我想知道是否有代码示例，可以在Flink程序中加载预先训练好的编码模型(用python编写)
The Apache Flink community is excited to announce the release of Flink ML
2.1.0!
This release focuses on improving Flink ML's infrastructure, such as Python
SDK, memory management, and benchmark framework, to facilitate the
development of performant, memory-safe, and easy-to-use algorithm
D.
>
> On Fri, Jan 7, 2022 at 2:27 PM Yun Gao wrote:
>
>> The Apache Flink community is very happy to announce the release of
>> Apache Flink ML 2.0.0.
>>
>>
>>
>> Apache Flink ML provides API and infrastructure that simplifies
>> implementing d
Great job! <3 Thanks Dong and Yun for managing the release and big thanks
to everyone who has contributed!
Best,
D.
On Fri, Jan 7, 2022 at 2:27 PM Yun Gao wrote:
> The Apache Flink community is very happy to announce the release of Apache
> Flink ML 2.0.0.
>
>
>
> Apache
The Apache Flink community is very happy to announce the release of Apache
Flink ML 2.0.0.
Apache Flink ML provides API and infrastructure that simplifies implementing
distributed ML algorithms,
and it also provides a library of off-the-shelf ML algorithms.
Please check out the release blog
