Re: How to sink invalid data from flatmap

s it means I’ve to use process to rewrite > my flatmap function? > > 发件人: Jake [mailto:ft20...@qq.com] > 发送时间: 2020年8月25日 星期二 11:06 > 收件人: 范超 > 抄送: user > 主题: Re: How to sink invalid data from flatmap > > Hi fanchao > > use side output, see[1] > &

Re: How to sink invalid data from flatmap

Hi fanchao use side output, see[1] [1]https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/side_output.html Jake > On Aug 25, 2020, at 10:54 AM, 范超 wrote: > > Hi, > I’m using the c

Re: How to sink invalid data from flatmap

Hi Chao I think side output [1] might meet your requirements. [1] https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html Best Yun Tang From: 范超 Sent: Tuesday, August 25, 2020 10:54 To: user Subject: How to sink invalid data from fla