Hi Baswaraj,
when you are using the ./bin/flink run client for submitting jobs, the
StreamExecutionEnvironment.getExecutionEnvironment(); call is the correct
one to retrieve the Execution Environment.
So you can not use the RemoteEnvironment with the ./bin/flink tool..
The purpose of the remote e
I am using flink 1.1.1.
I am trying to run flink streaming program (kafka as source).
It works perfectly when I use
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
But, problem is when I use one of the following to create env.
StreamExecutionEnvironment env
