Hellow everyone :

       Up to now, To adjuest rocksdb flush thread  the only way is implement 
ConfigurableRocksDBOptionsFactory #setMaxBackgroundFlushes by user. I found 
FLINK-22059 to solve this problem. The pr has never been executed, i want to 
finish this pr. Can anyone  assignee this pr to me ? My jira id is 
:zhongyou.lee.

benefity from this pr

Improve rocksdb write performance . Such as: multi slot per TaskManagers , 
savepoint recovery.

how to finish those pr

Add state.backend.rocksdb.flush.thread.num in RocksDBConfigurableOptions and 
flink configure document description 

Use  currentOptions.getEnv().setBackgroundThreads() instend of 
setMaxBackgroundFlushes method to change thread.(which support in 5.17 and 
above rocksdb)

tell user above rocksdb 5.17 and below version rocksdb setMaxBackgroundFlushes 
api has problem as below:https://github.com/facebook/rocksdb/issues/4847. 

Reply via email to