Browse Source

KAFKA-6100: Down-grade RocksDB to 5.7.3

Author: Guozhang Wang <wangguoz@gmail.com>

Reviewers: Vahid Hashemian <vahidhashemian@us.ibm.com>, Damian Guy <damian.guy@gmail.com>, Bill Bejeck <bill@confluent.io>

Closes #4136 from guozhangwang/K6100-rocksdb-580-regression
pull/4083/merge
Guozhang Wang 7 years ago
parent
commit
ea6a67af70
  1. 2
      gradle/dependencies.gradle
  2. 5
      streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java

2
gradle/dependencies.gradle

@ -64,7 +64,7 @@ versions += [ @@ -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",

5
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> { @@ -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);
}
}

Loading…
Cancel
Save