[DISCUSS] Flexible Custom Commit Policy with Parameter Passing

2023-06-20 Thread Gary Ccc
To the Apache Flink Community Members, I hope this email finds you well. I am writing to discuss a potential improvement for the implementation of a custom commit policy in Flink. Background: We have encountered challenges in utilizing a custom commit policy due to the inability to pass parameters

Re: [DISCUSS] Flexible Custom Commit Policy with Parameter Passing

2023-06-20 Thread Gary Ccc
will it better to make it > asList? Something like: > `.stringType().asList()`. > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Gary Ccc" > 收件人: "dev" > 发送时间: 星期二, 2023年 6 月 20日 下午 5:44:10 > 主题: [DISCUSS] Flexible Custom Commit Policy with Para