Thanks Guowei! I'll check it out.
Best,
Zhanghao Chen
From: Guowei Ma
Sent: Wednesday, April 6, 2022 16:01
To: Zhanghao Chen
Cc: user@flink.apache.org
Subject: Re: Why first op after union cannot be chained?
Hi Zhanghao
AFAIK, you might to see
Hi Zhanghao
AFAIK, you might to see the `StreamingJobGraphGenerator` not the
`JobGraphGenerator` which is only used by the old flink stream sql stack.
>From comment of the `StreamingJobGraphGenerator::isChainableInput` the `an
union operator` does not support chain currently.
Best,
Guowei
On
Dear all,
I was recently investigating why the chaining behavior of a Flink SQL job
containing union ops is a bit surprising. The SQL, simplified to the extreme,
is as below:
CREATE TABLE datagen_source (word VARCHAR)
WITH ('connector' = 'datagen', 'rows-per-second' = '5');
CREATE
