You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/04/19 09:13:46 UTC
[4/4] flink git commit: [hotfix][statebackend] Removed use of rawtype
access for generic collection
[hotfix][statebackend] Removed use of rawtype access for generic collection
(cherry picked from commit d1725a9)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ccdf07d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ccdf07d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2ccdf07d
Branch: refs/heads/release-1.5
Commit: 2ccdf07da3ee437bbb889d3fea9b1b9cf4a19637
Parents: e6659b0
Author: Stefan Richter <s....@data-artisans.com>
Authored: Wed Apr 18 18:25:15 2018 +0200
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Thu Apr 19 11:13:26 2018 +0200
----------------------------------------------------------------------
.../flink/contrib/streaming/state/RocksDBKeyedStateBackend.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2ccdf07d/flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
----------------------------------------------------------------------
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 3000667..ad40c70 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
@@ -1195,10 +1195,9 @@ public class RocksDBKeyedStateBackend<K> extends AbstractKeyedStateBackend<K> {
throw new IOException("Error creating ColumnFamilyHandle.", e);
}
- Tuple2<ColumnFamilyHandle, RegisteredKeyedBackendStateMetaInfo<N, S>> tuple =
+ Tuple2<ColumnFamilyHandle, RegisteredKeyedBackendStateMetaInfo<?, ?>> tuple =
new Tuple2<>(columnFamily, newMetaInfo);
- Map rawAccess = kvStateInformation;
- rawAccess.put(descriptor.getName(), tuple);
+ kvStateInformation.put(descriptor.getName(), tuple);
return columnFamily;
}