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 Jark
Thanks for your reploy.
In my code, i use `TableEnvironemnt` with Blink planner.
this.tableEnv = StreamTableEnvironment.create(
env,
EnvironmentSettings.newInstance()
.useBlinkPlanner()
.inStreamingMode()
.build());
// update three sql
sqlsWithoutFunc.forEach(sql -> {
tableEnv.sqlUpdate(
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
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
