kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Upgrade RocksDB to 5.13.4 (#5309)
Date Fri, 29 Jun 2018 18:10:26 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 7947c94  MINOR: Upgrade RocksDB to 5.13.4 (#5309)
7947c94 is described below

commit 7947c94140dbcfa1ce78bd35d400bb309470fc81
Author: Guozhang Wang <wangguoz@gmail.com>
AuthorDate: Fri Jun 29 11:10:21 2018 -0700

    MINOR: Upgrade RocksDB to 5.13.4 (#5309)
    
    Reviewers: Bill Bejeck <bill@confluent.io>, Matthias J. Sax <matthias@confluent.io>
---
 gradle/dependencies.gradle                                           | 2 +-
 .../java/org/apache/kafka/streams/state/internals/RocksDBStore.java  | 5 -----
 2 files changed, 1 insertion(+), 6 deletions(-)

diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle
index 130b6a3..bdcc014 100644
--- a/gradle/dependencies.gradle
+++ b/gradle/dependencies.gradle
@@ -76,7 +76,7 @@ versions += [
   // PowerMock 1.x doesn't support Java 9, so use PowerMock 2.0.0 beta
   powermock: "2.0.0-beta.5",
   reflections: "0.9.11",
-  rocksDB: "5.7.3",
+  rocksDB: "5.13.4",
   scalatest: "3.0.5",
   scoverage: "1.3.1",
   slf4j: "1.7.25",
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
index e858ac0..17d03cc 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java
@@ -248,11 +248,6 @@ public class RocksDBStore implements KeyValueStore<Bytes, byte[]>
{
                 } catch (final RocksDBException e) {
                     throw new ProcessorStateException("Error while range compacting during
restoring  store " + this.name, e);
                 }
-
-                // we need to re-open with the old num.levels again, this is a workaround
-                // until https://github.com/facebook/rocksdb/pull/2740 is merged in rocksdb
-                close();
-                openDB(internalProcessorContext);
             }
         }
 


Mime
View raw message