Does RocksDBStateBackend need a separate RocksDB service？

In  my  code,  I just setStateBackend with a hdfs direcoty.

           env.setStateBackend(new RocksDBStateBackend("hdfs://user/test/job")); 

Is there an embeded  RocksDB  service in the flink task? 

---

[hidden email]

[miki haiat]

There  is no need to add an external RocksDB instance

  .

The RocksDBStateBackend holds in-flight data in a RocksDB database that is (per default) stored in the TaskManager data directories.  

[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/state_backends.html#the-rocksdbstatebackend

 

On Wed, Aug 7, 2019 at 1:25 PM [hidden email] <[hidden email]> wrote:

In  my  code,  I just setStateBackend with a hdfs direcoty.

           env.setStateBackend(new RocksDBStateBackend("hdfs://user/test/job")); 

Is there an embeded  RocksDB  service in the flink task? 

---

[hidden email]

[Biao Liu]

Hi wanglei,

> Is there an embeded  RocksDB  service in the flink task?

Yes, and "RocksDB is an embeddable persistent key-value store for fast storage". [1]

1. http://rocksdb.org/

On Wed, Aug 7, 2019 at 7:27 PM miki haiat <[hidden email]> wrote:

There  is no need to add an external RocksDB instance

  .

The RocksDBStateBackend holds in-flight data in a RocksDB database that is (per default) stored in the TaskManager data directories.  

[1] https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/state_backends.html#the-rocksdbstatebackend

 

On Wed, Aug 7, 2019 at 1:25 PM [hidden email] <[hidden email]> wrote:

In  my  code,  I just setStateBackend with a hdfs direcoty.

           env.setStateBackend(new RocksDBStateBackend("hdfs://user/test/job")); 

Is there an embeded  RocksDB  service in the flink task? 

---

[hidden email]