Checkpoint in FlinkSQL

[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

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

[何会远]

https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/checkpoints.html
At 2019-11-05 09:37:47, "Simon Su" <[hidden email]> wrote:

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