flinksql多sink案例

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flinksql多sink案例

todd
最近在看flinksql优化部分的代码,Flink在对多sink情况下进行公共子图的优化。所以想问下finksql执行多sink的案例,

在org.apache.flink.table.planner.plan.optimize.RelNodeBlockPlanBuilder#buildRelNodeBlockPlan中convertedRelNodes.size才能大于1.






--
Sent from: http://apache-flink.147419.n8.nabble.com/