flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [1/2] flink git commit: [FLINK-5173] Upgrade RocksDB dependency
Date Sat, 03 Dec 2016 07:57:41 GMT
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 <s.richter@data-artisans.com>
Authored: Sun Nov 13 05:04:03 2016 +0100
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
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 {


Mime
View raw message