Yi Pan (Data Infrastructure) created SAMZA-819: --------------------------------------------------
Summary: RocksDbKeyValueStore.flush() should be implemented Key: SAMZA-819 URL: https://issues.apache.org/jira/browse/SAMZA-819 Project: Samza Issue Type: Bug Affects Versions: 0.10.0 Reporter: Yi Pan (Data Infrastructure) Fix For: 0.10.0 The current code does not actually invoke db.flush(), due to lack of flush() method in the old RocksDb JNI API. With RocksDB 3.13.1, RocksDB.flush() method is exposed via JNI API and should be invoked in KV store's flush() method. -- This message was sent by Atlassian JIRA (v6.3.4#6332)