Github user buptljy commented on the issue:
https://github.com/apache/flink/pull/5628
@twalthr
Sorry for late reply here.
This can be closed now, and I'll submit another PR this week.
I've posted my solution in FLINK-6895, we can have a discussion there.---
