Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3117
@ShashwatRastogi-Reflektion I'm not entirely sure, but one thing you could
try is to explicitly disable chaining
(`StreamExecutionEnvironment#disableOperatorChaining`). This way the ID of each
operator (that now runs as a separate task) should be logged / be visible in
the UI.---
