Hi,

We configure rocksdb as statebackend and checkpoint dir persists to hdfs. When 
the job is run, rocksdb automatically mount to tmpfs /tmp, which consume memory.


            RocksDBStateBackend rocksdb = new RocksDBStateBackend(new 
FsStateBackend(hdfs://), true);
            env.setStateBackend(rocksdb);


Questions,

  1.  What happen if large state is larger than the tmpfs memory size? Will 
flink do something?
  2.  Is it possible to configure rocksdb dir via flink?

Thank you.

Regards,
Yow

Reply via email to