Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5465
---
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169631205
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +527,7
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169627770
--- Diff:
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169620794
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -319,6 +321,9 @@ pri
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169620758
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +530,7 @@ pri
Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169374194
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -400,7 +410,7 @@ pub
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169105350
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -400,7 +410,7 @
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169099355
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -319,6 +321,9 @
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169100675
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -400,7 +410,7 @
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5465#discussion_r169099948
--- Diff:
flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java
---
@@ -520,7 +530,7 @
GitHub user sihuazhou opened a pull request:
https://github.com/apache/flink/pull/5465
[FLINK-8639][State Backends]Fix always need to seek multiple times when
iterator RocksDBMapState
## What is the purpose of the change
This PR addressed issue
[FLINK-8639](https://issues.
11 matches
Mail list logo