[hotfix] Replace use of deprecated remove calls to RocksDB with delete

Jin-H · Feb 25, 2018 · ff6662c · ff6662c
1 parent c2c4f49
commit ff6662c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java b/...-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/AbstractRocksDBState.java
@@ -102,7 +102,7 @@ public void clear() {
 		try {
 			writeCurrentKeyWithGroupAndNamespace();
 			byte[] key = keySerializationStream.toByteArray();
-			backend.db.remove(columnFamily, writeOptions, key);
+			backend.db.delete(columnFamily, writeOptions, key);
 		} catch (IOException | RocksDBException e) {
 			throw new RuntimeException("Error while removing entry from RocksDB", e);
 		}

diff --git a/...ckend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java b/...ckend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
@@ -123,7 +123,7 @@ public void putAll(Map<UK, UV> map) throws IOException, RocksDBException {
 	public void remove(UK userKey) throws IOException, RocksDBException {
 		byte[] rawKeyBytes = serializeUserKeyWithCurrentKeyAndNamespace(userKey);
 
-		backend.db.remove(columnFamily, writeOptions, rawKeyBytes);
+		backend.db.delete(columnFamily, writeOptions, rawKeyBytes);
 	}
 
 	@Override
@@ -339,7 +339,7 @@ public void remove() {
 			rawValueBytes = null;
 
 			try {
-				db.remove(columnFamily, writeOptions, rawKeyBytes);
+				db.delete(columnFamily, writeOptions, rawKeyBytes);
 			} catch (RocksDBException e) {
 				throw new RuntimeException("Error while removing data from RocksDB.", e);
 			}