Github user HeartSaVioR commented on the issue:
https://github.com/apache/flink/pull/6253
@fhueske
Thanks for the nice feedback! Addressed your comment except regarding unit
test. Let me try out adding unit test later, since it might bring too high
barrier as of now.---
