state backend configuration

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

state backend configuration

Jayant Ameta
Hi,
Can I enable incremental checkpoint for rocksdb via flink-conf.yaml file?

Also, I can set state.backend via the conf file as well as in my code using env.setStateBackend(). Which of these take precedence?

Jayant Ameta
Reply | Threaded
Open this post in threaded view
|

Re: state backend configuration

Aljoscha Krettek
Hi,

This is not possible on versions of Flink prior to 1.5 but starting with that (as of yet unreleased) versions you'll be able to configure this via state.backend.incremental: true.

Configurations that you do in code will take precedence.

Best,
Aljoscha

> On 14. Mar 2018, at 02:33, Jayant Ameta <[hidden email]> wrote:
>
> Hi,
> Can I enable incremental checkpoint for rocksdb via flink-conf.yaml file?
>
> Also, I can set state.backend via the conf file as well as in my code using env.setStateBackend(). Which of these take precedence?
>
> Jayant Ameta