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.
Hi All,
My task manager memory goes on increasing in idle stages also any
reason why so.
As a result of the above my job is failing.
Thanks in advance.
Thanks & regards,
Ganesh Walse
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 refe
Thanks for your confirmation,Yunfeng.
-- --
??:
"Yunfeng Zhou"
