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

Posted to commits@samza.apache.org by "Navina Ramesh (JIRA)" <ji...@apache.org> on 2015/11/20 23:45:10 UTC

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

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

Navina Ramesh resolved SAMZA-819.
---------------------------------
    Resolution: Fixed

Committed. Thanks for the patch, [~TaoFeng] !

> 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 Feng
>             Fix For: 0.10.0
>
>         Attachments: SAMZA-819.2.patch, SAMZA-819.patch
>
>
> 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)