You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2021/12/21 14:05:59 UTC
[flink] 01/01: Other renaming
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 <tr...@apache.org>
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);