This is an automated email from the ASF dual-hosted git repository. trohrmann pushed a commit to branch pull/18161/head in repository https://gitbox.apache.org/repos/asf/flink.git
commit d03b921929b6ebe5afd78549ad1aa1bfc03a2273 Author: Till Rohrmann <[email protected]> AuthorDate: Tue Dec 21 15:05:05 2021 +0100 Other renaming --- .../contrib/streaming/state/RocksDBKeyedStateBackend.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java index 4e212a8..2410e15 100644 --- a/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java +++ b/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java @@ -773,16 +773,16 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { AbstractRocksDBState<?, ?, SV> rocksDBState = (AbstractRocksDBState<?, ?, SV>) state; Snapshot rocksDBSnapshot = db.getSnapshot(); - try (RocksIteratorWrapper iteratorRocks = + try (RocksIteratorWrapper iteratorRocksDb = RocksDBOperationUtils.getRocksIterator(db, stateMetaInfo.f0, readOptions); RocksDBWriteBatchWrapper batchWriter = new RocksDBWriteBatchWrapper(db, getWriteOptions(), getWriteBatchSize())) { - iteratorRocks.seekToFirst(); + iteratorRocksDb.seekToFirst(); DataInputDeserializer serializedValueInput = new DataInputDeserializer(); DataOutputSerializer migratedSerializedValueOutput = new DataOutputSerializer(512); - while (iteratorRocks.isValid()) { - serializedValueInput.setBuffer(iteratorRocks.value()); + while (iteratorRocksDb.isValid()) { + serializedValueInput.setBuffer(iteratorRocksDb.value()); rocksDBState.migrateSerializedValue( serializedValueInput, @@ -792,11 +792,11 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> { batchWriter.put( stateMetaInfo.f0, - iteratorRocks.key(), + iteratorRocksDb.key(), migratedSerializedValueOutput.getCopyOfBuffer()); migratedSerializedValueOutput.clear(); - iteratorRocks.next(); + iteratorRocksDb.next(); } } finally { db.releaseSnapshot(rocksDBSnapshot);
