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 5444dee443851..8f95b1812d844 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
@@ -680,7 +680,7 @@ private void restoreKVStateData() throws IOException, RocksDBException {
 							if (RocksDBFullSnapshotOperation.hasMetaDataFollowsFlag(key)) {
 								//clear the signal bit in the key to make it ready for insertion again
 								RocksDBFullSnapshotOperation.clearMetaDataFollowsFlag(key);
-								rocksDBKeyedStateBackend.db.put(handle, rocksDBKeyedStateBackend.writeOptions, key, value);
+								rocksDBKeyedStateBackend.db.put(handle, key, value);
 								//TODO this could be aware of keyGroupPrefixBytes and write only one byte if possible
 								kvStateId = RocksDBFullSnapshotOperation.END_OF_KEY_GROUP_MARK
 									& compressedKgInputView.readShort();
@@ -690,7 +690,7 @@ private void restoreKVStateData() throws IOException, RocksDBException {
 									handle = currentStateHandleKVStateColumnFamilies.get(kvStateId);
 								}
 							} else {
-								rocksDBKeyedStateBackend.db.put(handle, rocksDBKeyedStateBackend.writeOptions, key, value);
+								rocksDBKeyedStateBackend.db.put(handle, key, value);
 							}
 						}
 					}
@@ -1091,7 +1091,6 @@ private void restoreKeyGroupsShardWithTemporaryHelperInstance(
 
 								if (stateBackend.keyGroupRange.contains(keyGroup)) {
 									stateBackend.db.put(targetColumnFamilyHandle,
-										stateBackend.writeOptions,
 										iterator.key(), iterator.value());
 								}