You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Yi Pan (Data Infrastructure) (JIRA)" <ji...@apache.org> on 2015/11/19 08:16:11 UTC

[jira] [Updated] (SAMZA-819) RocksDbKeyValueStore.flush() should be implemented

     [ https://issues.apache.org/jira/browse/SAMZA-819?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Yi Pan (Data Infrastructure) updated SAMZA-819:
-----------------------------------------------
    Assignee: Tao

> 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)
>            Assignee: Tao
>             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)