Re: Checkpoint in FlinkSQL

2019-11-04 Thread 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  于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

2019-11-04 Thread 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 
Date: Tuesday, November 5, 2019 at 10:38 AM
To: dev , user 
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