[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5465 ---

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-21 Thread sihuazhou
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

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-21 Thread StefanRRichter
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] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-21 Thread sihuazhou
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 @@

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-21 Thread sihuazhou
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 @@

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-20 Thread sihuazhou
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 @@

[GitHub] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-19 Thread StefanRRichter
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] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-19 Thread StefanRRichter
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] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-19 Thread StefanRRichter
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] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-19 Thread StefanRRichter
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] flink pull request #5465: [FLINK-8639][State Backends]Fix always need to see...

2018-02-12 Thread sihuazhou
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