Hi forideal,
You are using `StreamTableEnvironment` which doesn't support multi-sink
optimization in 1.10 :)
You should change `StreamTableEnvironment.create` to
`TableEnvironment.create`.
Btw, StreamTableEnvironment will also support multi-sink optimization in
1.11.
Best,
Jark
On Fri, 10 Apr
Hi forideal,
Are you using `StreamTableEnvironment` or SQL CLI?
Currently, only `TableEnvironemnt` with Blink planner have the multi-sink
optimization (reuse shared upstream operators).
Best,
Jark
On Fri, 10 Apr 2020 at 16:31, forideal wrote:
> Hello
>
>There are 3 SQLs all querying the sa
Hi forideal,
Currently, Blink planner with TableEnvironment supports multiple sinks
optimization which will try best to reuse common sub-graph.
Best,
Godfrey
forideal 于2020年4月10日周五 下午4:31写道：
> Hello
>
>There are 3 SQLs all querying the same table, but the generated GAG is
> 3 independent t
