Hi Jeff, the session functionality which you find in Flink's client are the remnants of an uncompleted feature which was abandoned. The idea was that one could submit multiple parts of a job to the same cluster where these parts are added to the same ExecutionGraph. That way we wanted to allow to reuse computed results when using a notebook for ad-hoc queries, for example. But as I said, this feature has never been completed.
Cheers, Till On Sun, Jun 2, 2019 at 3:20 PM Jeff Zhang <zjf...@gmail.com> wrote: > > 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 >
