Re: Checkpoint in FlinkSQL

2019-11-04 Thread vino yang
Hi Simon, Absolutely, yes. Before using Flink SQL, you need to initialize a StreamExecutionEnvirnoment instance[1], then call StreamExecutionEnvirnoment#setStateBackend or StreamExecutionEnvirnoment#enableCheckpointing to specify the information what you want. [1]: https://ci.apache.org/projects/

Re: Checkpoint in FlinkSQL

2019-11-04 Thread Yun Tang
://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html#checkpointing Best Yun Tang From: Simon Su Date: Tuesday, November 5, 2019 at 10:38 AM To: dev , user Subject: Checkpoint in FlinkSQL Hi All Does current Flink support to set checkpoint properties while using Flink SQL ? For example

Checkpoint in FlinkSQL

2019-11-04 Thread Simon Su
Hi All Does current Flink support to set checkpoint properties while using Flink SQL ? For example, statebackend choices, checkpoint interval and so on ... Thanks, SImon