Checkpoint in FlinkSQL

[Shu 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

[Yun Tang]

Hi Simon

 

If you are using table API, you could set state backend via environment like `env.setStateBackend()`

 

If you just launch a cluster with SQL-client, you could configure state backend and checkpoint options [1] within `flink-conf.yaml` before launching the cluster .

 

[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html#checkpointing

 

Best

Yun Tang

 

From: Simon Su <[hidden email]>
Date: Tuesday, November 5, 2019 at 10:38 AM
To: dev <[hidden email]>, user <[hidden email]>
Subject: Checkpoint in FlinkSQL

 

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

 

[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/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