Bowen Li created FLINK-8515: ------------------------------- Summary: update RocksDBMapState to replace deprecated remove() with delete() Key: FLINK-8515 URL: https://issues.apache.org/jira/browse/FLINK-8515 Project: Flink Issue Type: Improvement Components: State Backends, Checkpointing Affects Versions: 1.5.0 Reporter: Bowen Li Assignee: Bowen Li Fix For: 1.5.0
Currently in RocksDBMapState: {code:java} @Override public void remove(UK userKey) throws IOException, RocksDBException { byte[] rawKeyBytes = serializeUserKeyWithCurrentKeyAndNamespace(userKey); backend.db.remove(columnFamily, writeOptions, rawKeyBytes); } {code} remove() is actually deprecated. Should be replaced with delete() -- This message was sent by Atlassian JIRA (v7.6.3#76005)