Hello
There are 3 SQLs all querying the same table, but the generated GAG is 3
independent topologies.I think, the better result is that there is one Source
and 3 Sinks.
createtablegood_sink(datavarchar)with(
'connector.type'='console',
'connector.dry-run'='false','connector.property-version'='1','update-mode'='append');createtableatomic_sink(datavarchar)with('connector.type'='console','connector.dry-run'='false','connector.property-version'='1','update-mode'='append');createtablebad_sink(datavarchar)with('connector.type'='console','connector.dry-run'='false','connector.property-version'='1','update-mode'='append');createtablesource_stream(datavarchar,`key`varchar)with(xxx);insertintogood_sinkselectdatafromsource_streamwhere`key`='good';insertintoatomic_sinkselectdatafromsource_streamwhere`key`='atomic';insertintoatomic_sinkselectdatafromsource_streamwhere`key`='bad';
DAG picture
Link：https://pic4.zhimg.com/80/v2-7db1417bd2607d3a939f38cc19228df3_1440w.jpg
Question Link：https://zhuanlan.zhihu.com/p/128590984
Best Wishes
