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