Hi Team,

https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/#task-chaining-and-resource-groups



*Flink chaining my Tasks which is like: stream.map().filter().map() *

*I think here the entire chain runs in the same slot.*

*Documentation says flink does chahining for better performance, but are
there any scenarios we should disable or start a new chain mainly for the
purpose of better performance ?*

StreamExecutionEnvironment.disableOperatorChaining()

someStream.filter(...).map(...).startNewChain().map(...)

someStream.map(...).disableChaining()

Reply via email to