Repository: kafka Updated Branches: refs/heads/trunk adb9d5ae7 -> ea6a67af7
KAFKA-6100: Down-grade RocksDB to 5.7.3 Author: Guozhang Wang <[email protected]> Reviewers: Vahid Hashemian <[email protected]>, Damian Guy <[email protected]>, Bill Bejeck <[email protected]> Closes #4136 from guozhangwang/K6100-rocksdb-580-regression Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/ea6a67af Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/ea6a67af Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/ea6a67af Branch: refs/heads/trunk Commit: ea6a67af70c6ee811154ab947ce947e1bc0c3a20 Parents: adb9d5a Author: Guozhang Wang <[email protected]> Authored: Thu Oct 26 13:27:08 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Thu Oct 26 13:27:08 2017 -0700 ---------------------------------------------------------------------- gradle/dependencies.gradle | 2 +- .../org/apache/kafka/streams/state/internals/RocksDBStore.java | 5 +++++ 2 files changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/ea6a67af/gradle/dependencies.gradle ---------------------------------------------------------------------- diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle index f92b168..46ac7ed 100644 --- a/gradle/dependencies.gradle +++ b/gradle/dependencies.gradle @@ -64,7 +64,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.8.0", + rocksDB: "5.7.3", scalatest: "3.0.4", scoverage: "1.3.1", slf4j: "1.7.25", http://git-wip-us.apache.org/repos/asf/kafka/blob/ea6a67af/streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java ---------------------------------------------------------------------- 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 c219314..ea01694 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 @@ -269,6 +269,11 @@ public class RocksDBStore<K, V> implements KeyValueStore<K, V> { } catch (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); } }
