You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Simon Su <ba...@163.com> on 2019/11/05 02:37:47 UTC

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

Re: Checkpoint in FlinkSQL

Posted by vino yang <ya...@gmail.com>.

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 <ba...@163.com> 于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
>
>

Re: Checkpoint in FlinkSQL

Posted by Yun Tang <my...@live.com>.

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 <ba...@163.com>
Date: Tuesday, November 5, 2019 at 10:38 AM
To: dev <de...@flink.apache.org>, user <us...@flink.apache.org>
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

Re:Checkpoint in FlinkSQL

Posted by 何会远 <kn...@163.com>.

https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/checkpoints.html
At 2019-11-05 09:37:47, "Simon Su" <ba...@163.com> 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
>

Re: Checkpoint in FlinkSQL

Posted by Yun Tang <my...@live.com>.

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 <ba...@163.com>
Date: Tuesday, November 5, 2019 at 10:38 AM
To: dev <de...@flink.apache.org>, user <us...@flink.apache.org>
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

Re: Checkpoint in FlinkSQL

Posted by vino yang <ya...@gmail.com>.

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 <ba...@163.com> 于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
>
>