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 PM Enric Ott <243816...@qq.com> 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.
