Re: Checkpoint in FlinkSQL

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

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