Thanks for your confirmation,Yunfeng.



------------------ ???????? ------------------
??????:                                                                         
                                               "Yunfeng Zhou"                   
                                                                 
<flink.zhouyunf...@gmail.com&gt;;
????????:&nbsp;2024??7??5??(??????) ????9:46
??????:&nbsp;"Enric Ott"<243816...@qq.com&gt;;"user"<user@flink.apache.org&gt;;

????:&nbsp;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 <243816...@qq.com&gt; wrote:
&gt;
&gt; Hello,guys:
&gt;&nbsp;&nbsp; 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.
&gt;&nbsp;&nbsp; Thanks.

Reply via email to