Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5923
Honestly, I did not find the proposed change too convincing either due to
the additional branch into bounded vs. unbounded partitions which caused the
variable names to be wrong in the unbounded case. Instead I submitted a
slightly changed not so compact more explicit variant. Hopefully that is more
clear now.---
