Github user dawidwys commented on the issue: https://github.com/apache/flink/pull/5580 @zentol I agree it will need to be changed in the end (though wouldn't say rewritten completely) after the submission process is completed. I think though this change is important from the perspective of integration with portability layer in beam. Would be glad to hear @aljoscha's opinion on that.
---