From 46230e4f6ea54864672c7feaa3ec9d8ab89de563 Mon Sep 17 00:00:00 2001 From: intsmaze Date: Mon, 14 Jan 2019 16:42:12 +0800 Subject: [PATCH] Update state_backends.md Stateback provides api implementations of FsStateBackend and MemoryStateBackend by default. Add the RocksDBStateBackend dependency if you want to use the RocksDBStateBackend api. --- docs/ops/state/state_backends.md | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/docs/ops/state/state_backends.md b/docs/ops/state/state_backends.md index e4fe5bda06304..7307d7e67c163 100644 --- a/docs/ops/state/state_backends.md +++ b/docs/ops/state/state_backends.md @@ -146,6 +146,17 @@ env.setStateBackend(new FsStateBackend("hdfs://namenode:40010/flink/checkpoints" +Stateback provides api implementations of FsStateBackend and MemoryStateBackend by default. +If you want to set Per-job state backend to RocksDBStateBackend, you need to add a dependency in your Flink project. + +{% highlight xml %} + + org.apache.flink + flink-statebackend-rocksdb{{ site.scala_version_suffix }} + {{site.version }} + +{% endhighlight %} + ### Setting Default State Backend