You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/01/15 09:55:15 UTC
kafka git commit: MINOR: replace remove() with delete() after 5.0.1
RocksDB upgrade
Repository: kafka
Updated Branches:
refs/heads/trunk da57bc27e -> d2f6b934b
MINOR: replace remove() with delete() after 5.0.1 RocksDB upgrade
Author: Guozhang Wang <wa...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #2380 from guozhangwang/KMinor-remove-deprecated-rocksDB
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d2f6b934
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d2f6b934
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d2f6b934
Branch: refs/heads/trunk
Commit: d2f6b934bcbd8feca561e050ff8e18d0a4db7d61
Parents: da57bc2
Author: Guozhang Wang <wa...@gmail.com>
Authored: Sun Jan 15 09:55:11 2017 +0000
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Sun Jan 15 09:55:11 2017 +0000
----------------------------------------------------------------------
.../org/apache/kafka/streams/state/internals/RocksDBStore.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/d2f6b934/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 f838191..8b838d0 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
@@ -253,7 +253,7 @@ public class RocksDBStore<K, V> implements KeyValueStore<K, V> {
private void putInternal(byte[] rawKey, byte[] rawValue) {
if (rawValue == null) {
try {
- db.remove(wOptions, rawKey);
+ db.delete(wOptions, rawKey);
} catch (RocksDBException e) {
throw new ProcessorStateException("Error while removing key " + serdes.keyFrom(rawKey) +
" from store " + this.name, e);
@@ -274,7 +274,7 @@ public class RocksDBStore<K, V> implements KeyValueStore<K, V> {
for (KeyValue<K, V> entry : entries) {
final byte[] rawKey = serdes.rawKey(entry.key);
if (entry.value == null) {
- db.remove(rawKey);
+ db.delete(rawKey);
} else {
final byte[] value = serdes.rawValue(entry.value);
batch.put(rawKey, value);