Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/6300
I like the idea of this - should make it much easier to use.
Have you run this code on some heavier data stream to validate that it
works well in practice?
If yes, I would be +1 to this---
