Hi Xiangyu Feng, Thanks for the FLIP. Could you elaborate on why Statement Sets aren't sufficient here, I can't find that in the FLIP.
Best regards, Martijn On Thu, Feb 6, 2025 at 10:06 AM xiangyu feng <xiangyu...@gmail.com> wrote: > Hi devs, > > I'm opening this thread to discuss FLIP-506: Support Reuse Multiple Table > Sinks in Planner[1]. > > Currently if users want to partial-update a downstream table from multiple > source tables in one datastream, they would have to manually union all > source tables and add lots of "cast(null as string) as xxx" in Flink SQL. > This will make the SQL here hard to use and maintain. > > After discussing with Weijie Guo, we think that by supporting reuse sink > nodes in planner, the usability can be greatly improved in this case. > > Therefore, we propose to add a new option > *`table.optimizer.reuse-sink-enabled`* here to support this feature. More > details can be found in the FLIP. > > Looking forward to your feedback, thanks. > > [1] > > https://cwiki.apache.org/confluence/display/FLINK/FLIP-506%3A+Support+Reuse+Multiple+Table+Sinks+in+Planner > > Best regards, > Xiangyu Feng >