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