flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yun Tang <myas...@live.com>
Subject Re: Checkpoint in FlinkSQL
Date Tue, 05 Nov 2019 02:54:44 GMT
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

Yun Tang

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


View raw message