From 060784466eec1732a282016060c6db060ff34a28 Mon Sep 17 00:00:00 2001 From: "Tzu-Li (Gordon) Tai" Date: Mon, 16 Aug 2021 13:37:28 +0800 Subject: [PATCH] [FLINK-22752] More robust state configurations in base flink-conf.yaml --- template/flink-distribution/conf/flink-conf.yaml | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/template/flink-distribution/conf/flink-conf.yaml b/template/flink-distribution/conf/flink-conf.yaml index 8b9b4e4..2011749 100644 --- a/template/flink-distribution/conf/flink-conf.yaml +++ b/template/flink-distribution/conf/flink-conf.yaml @@ -35,11 +35,18 @@ restart-strategy: fixed-delay restart-strategy.fixed-delay.attempts: 2147483647 restart-strategy.fixed-delay.delay: 1sec +state.backend.local-recovery: true state.backend: rocksdb state.backend.rocksdb.timer-service.factory: ROCKSDB +state.backend.rocksdb.localdir: /local/state/rocksdb +state.backend.rocksdb.memory.partitioned-index-filters: true +state.backend.rocksdb.checkpoint.transfer.thread.num: 8 +state.backend.rocksdb.thread.num: 4 state.checkpoints.dir: file:///checkpoint-dir state.backend.incremental: true +taskmanager.state.local.root-dirs: file:///local/state/recovery + #============================================================================== # Recommended memory configurations. Users may change according to their needs. #==============================================================================