Re: Checkpoint in FlinkSQL

Posted by vino yang on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Checkpoint-in-FlinkSQL-tp30881p30883.html

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/flink/flink-docs-release-1.9/dev/table/sql.html#specifying-a-query

Best,

Vino

Simon Su <[hidden email]> 于2019年11月5日周二 上午10:38写道：

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