Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/5552
I will have a look at the current state of the PR, but given that you
started the effort, it would be good for completeness, to also refactor the
`scala` equivalent `ITcase` to get rid of all the anonymous/internal/whatever
classes, that mess up the extensibility of the `ITcase`. ---
