|
@@ -247,7 +247,7 @@ public class RocksDBStore implements MetadataStore {
|
|
for (BatchOperation.SingleOperation opt : operations) {
|
|
for (BatchOperation.SingleOperation opt : operations) {
|
|
switch (opt.getOpt()) {
|
|
switch (opt.getOpt()) {
|
|
case DELETE:
|
|
case DELETE:
|
|
- writeBatch.remove(opt.getKey());
|
|
|
|
|
|
+ writeBatch.delete(opt.getKey());
|
|
break;
|
|
break;
|
|
case PUT:
|
|
case PUT:
|
|
writeBatch.put(opt.getKey(), opt.getValue());
|
|
writeBatch.put(opt.getKey(), opt.getValue());
|