Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-14 Thread Kevin Cheng
> > >> > > > > > >> Regards, > > > > > >> Xiangyu Feng > > > > > >> > > > > > >> xiangyu feng 于2025年2月11日周二 13:46写道: > > > > > >> > > > > > >>> Hi Yanquan, > > > > > >>> &

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-13 Thread xiangyu feng
ces. If not, a SQL validation exception > > should > > > > be > > > > >>> raised for planner. > > > > >>> > > > > >>> Regards, > > > > >>> Xiangyu Feng > > > > >>> > > > >

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-13 Thread Ron Liu
gt; > be > > > >>> raised for planner. > > > >>> > > > >>> Regards, > > > >>> Xiangyu Feng > > > >>> > > > >>> > > > >>> > > > >>> Yanquan Lv 于2025年2月10日周一 16:25写道: &g

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-12 Thread xiangyu feng
i, Xiangyu. Thanks for driving this. > > >>>> > > >>>> I have a question to confirm: > > >>>> Considering the case that different Sources use different > columns[1], > > >>>> will the Schema of CatalogTable[2] contain all tar

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-12 Thread Ron Liu
rces use different columns[1], > >>>> will the Schema of CatalogTable[2] contain all target columns for > Sources? > >>>> And for SinkWriter, the data structure to be processed should be > fixed. > >>>> Is there a node or a

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-12 Thread xiangyu feng
field of Rowdata >>>> that passed from different Sources? >>>> >>>> [1] >>>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-506%3A+Support+Reuse+Multiple+Table+Sinks+in+Planner >>>> [2] >>>> https://nightlies.apache.org/flink/fl

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-10 Thread xiangyu feng
rg/confluence/display/FLINK/FLIP-506%3A+Support+Reuse+Multiple+Table+Sinks+in+Planner >> [2] >> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#planning >> >> >> >> > 2025年2月6日 17:06,xiangyu feng 写道: >> > &g

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-10 Thread xiangyu feng
Sources? >>> >>> [1] >>> https://cwiki.apache.org/confluence/display/FLINK/FLIP-506%3A+Support+Reuse+Multiple+Table+Sinks+in+Planner >>> [2] >>> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sourcessinks/#planning >>> >>> >>>

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-10 Thread xiangyu feng
nning > > > > > 2025年2月6日 17:06,xiangyu feng 写道: > > > > 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 downst

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-10 Thread Yanquan Lv
/sourcessinks/#planning > 2025年2月6日 17:06,xiangyu feng 写道: > > 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

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-06 Thread xiangyu feng
ent here, I can't find that in the FLIP. > > Best regards, > > Martijn > > On Thu, Feb 6, 2025 at 10:06 AM xiangyu feng wrote: > > > Hi devs, > > > > I'm opening this thread to discuss FLIP-506: Support Reuse Multiple Table > > Sinks in Planner[

Re: [DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-06 Thread Martijn Visser
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 wrote: > Hi devs, > > I'm opening this thread to discuss FLIP-506

[DISCUSS] FLIP-506: Support Reuse Multiple Table Sinks in Planner

2025-02-06 Thread xiangyu feng
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 "ca