Repository: flink Updated Branches: refs/heads/master 4e336c692 -> e4f802dd5
[FLINK-5173] Upgrade RocksDB dependency Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6e98a935 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6e98a935 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6e98a935 Branch: refs/heads/master Commit: 6e98a9357903b113f76b2a7e91e2049c6e88fb35 Parents: 4e336c6 Author: Stefan Richter <[email protected]> Authored: Sun Nov 13 05:04:03 2016 +0100 Committer: Aljoscha Krettek <[email protected]> Committed: Fri Dec 2 18:00:30 2016 +0100 ---------------------------------------------------------------------- flink-contrib/flink-statebackend-rocksdb/pom.xml | 2 +- .../flink/contrib/streaming/state/RocksDBKeyedStateBackend.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6e98a935/flink-contrib/flink-statebackend-rocksdb/pom.xml ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-statebackend-rocksdb/pom.xml b/flink-contrib/flink-statebackend-rocksdb/pom.xml index ef5e563..f2607e3 100644 --- a/flink-contrib/flink-statebackend-rocksdb/pom.xml +++ b/flink-contrib/flink-statebackend-rocksdb/pom.xml @@ -57,7 +57,7 @@ under the License. <dependency> <groupId>org.rocksdb</groupId> <artifactId>rocksdbjni</artifactId> - <version>4.5.1</version> + <version>4.11.2</version> </dependency> <!-- test dependencies --> http://git-wip-us.apache.org/repos/asf/flink/blob/6e98a935/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java index f332d1e..e498b34 100644 --- a/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java +++ b/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java @@ -231,9 +231,9 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { // Dispose decoupled db if (cleanupRockDBReference != null) { for (Tuple2<ColumnFamilyHandle, StateDescriptor<?, ?>> column : kvStateInformation.values()) { - column.f0.dispose(); + column.f0.close(); } - cleanupRockDBReference.dispose(); + cleanupRockDBReference.close(); } try {
