是的，当前 PyFlink 还不支持 side output，side output 的支持已经完成开发，会在接下来发布的 1.16 版本中支持。
On Thu, Aug 4, 2022 at 11:50 AM yidan zhao <hinobl...@gmail.com> wrote: > 1 需求是根据输入流，根据字段判定，拆分并输出为2个流。 > > 2 目前看 pyflink 的 api，貌似不支持 sideoutput。 > > 3 虽然可以基于输入流 A，连续处理2次，即输入流 A 流向算子 B 和算子 C，分别筛选自己需要的数据进行处理。但这样会导致数据重复传输。 >
