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
>

Reply via email to