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/ Thanks, Biao /'bɪ.aʊ/ On Wed, Aug 7, 2019 at 7:27 PM miki haiat <miko5...@gmail.com> wrote: > There is no need to add an external RocksDB instance > . > *The RocksDBStateBackend holds in-flight data in a RocksDB > <http://rocksdb.org/> 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 wangl...@geekplus.com.cn < > wangl...@geekplus.com.cn> 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? >> >> ------------------------------ >> wangl...@geekplus.com.cn >> >
