Hi Folks,
When I read the flink client api code, the concept of session is a little vague and unclear to me. It looks like the session concept is only applied in batch mode (I only see it in ExecutionEnvironment but not in StreamExecutionEnvironment). But for local mode (LocalExecutionEnvironment), starting one new session is starting one new MiniCluster, but in remote mode (RemoteExecutionEnvironment), starting one new session is just starting one new ClusterClient instead of one new cluster. So I am confused what does flink session really mean. Could anyone help me understand this ? Thanks. -- Best Regards Jeff Zhang