Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/5172 @suez1224 Thanks a lot for the contribution! I've had a look and the changes LGTM. I did have a comment regarding injecting a dependency for the runner, which I've added a commit for. Can you take a look at 2ffa659 before I actually merge this, and let me know what you think? Thanks! Will make sure this gets in for Flink 1.4.1 ..