Hi Ben, You can try using StreamExecutionEnvironment streamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment(); instead of directly creating a new one. This will allow to pick up the configuration parameters you pass through the command line.
I hope this helps, Kostas On Sun, Dec 20, 2020 at 7:46 AM Ben Beasley <calicode...@gmail.com> wrote: > > I was wondering if I could get help with the issue described in this > stackoverflow post.
