Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5966
@EronWright Just saw this - I have concurrently reworked this PR into #6326
which does things more cleanly. I would like to get that PR in for 1.6 (got
many users asking for this).
I would be happy if you want to build on top of that for the next steps...---
