Thanks for your confirmation,Yunfeng.
------------------ ???????? ------------------
??????:
"Yunfeng Zhou"
<[email protected]>;
????????: 2024??7??5??(??????) ????9:46
??????: "Enric Ott"<[email protected]>;"user"<[email protected]>;
????: Re: puzzle on OperatorChain
Hi Enric,
Yes that even if there is only one operator, StreamTask will still
create an OperatorChain for it. OperatorChain provides an abstract to
process events like endInputs, checkpoints and OperatorEvents in a
unified way, no matter how may operators are running in the
StreamTask. You may refer to StreamTask.operatorChain for its detailed
functionalities.
Best,
Yunfeng
On Thu, Jul 4, 2024 at 5:14?6?2PM Enric Ott <[email protected]> wrote:
>
> Hello,guys:
> Does Flink transform all operators(including source operator)
to OperatorChain even disableoperatorchaining was set to true and even the
OperatorChain contains only one single Operator.
> Thanks.