Github user zohar-mizrahi commented on the issue:
https://github.com/apache/flink/pull/5333
Just started to look at your changes and have one comment with respect to
the plan.py - have you tried executing the same script twice, but on the second
time change one line in the script (.e.g a map function)? Make sure the change
takes place for the second run.
(BTW - I'm not sure I'll be able to spend much time in the near future in
reviewing the whole changes)---
