What does flink session mean ?

2019-06-02 Thread Jeff Zhang
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

[jira] [Created] (FLINK-12704) Support blink planner

2019-06-02 Thread sunjincheng (JIRA)
sunjincheng created FLINK-12704: --- Summary: Support blink planner Key: FLINK-12704 URL: https://issues.apache.org/jira/browse/FLINK-12704 Project: Flink Issue Type: Sub-task Reporter

Re: [DISCUSS] FLIP-33: Standardize connector metrics

2019-06-02 Thread Becket Qin
Hi Piotr, Thanks for the suggestion. Some thoughts below: Re 1: The pending messages / bytes. I completely agree these are very useful metrics and we should expect the connector to report. WRT the way to expose them, it seems more consistent to add two metrics instead of adding a method (unless t

Re: [DISCUSS] Releasing Flink 1.8.1

2019-06-02 Thread jincheng sun
I am here to quickly update the progress of the issue that needs to be tracked: [Blocker] - FLINK-12296 [done] - FLINK-11987 [done] - FLINK-12297

[jira] [Created] (FLINK-12705) Allow user to specify the Hive version in use

2019-06-02 Thread Rui Li (JIRA)
Rui Li created FLINK-12705: -- Summary: Allow user to specify the Hive version in use Key: FLINK-12705 URL: https://issues.apache.org/jira/browse/FLINK-12705 Project: Flink Issue Type: Sub-task

Re: Checkpoint / Two Phase Commit

2019-06-02 Thread Piotr Nowojski
Hi, Sorry for late answer. > As I understand how it operates, the pre-phase state is when the checkpoint > is initiated and the checkpoint barrier advances from source to sink. Once > the pre-phase is complete (and successful), then the next step in the > process is where the "Sink" operator is e