Hey Guys, The .getExecutionEnvironment() method for the StreamingexecutionEnvironment does not work properly because we always return LocalEnvironment for running on the minicluster.
I was trying to figure out how to fix this but I got lost in the code trying to find how you determine whether the program was executed standalone or the command line client. Could you help me out with some pointers here? Regards, Gyula