Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641370
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java
---
@@ -20,6 +20,7 @@
import org.apache.flink.runti
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641519
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
---
@@ -949,8 +949,6 @@ public void run() {
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/3672#discussion_r127641085
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointStateRestoreTest.java
---
@@ -66,10 +66,19 @@
public void test
GitHub user guoweiM opened a pull request:
https://github.com/apache/flink/pull/3672
[Flink-6072] TestCase CheckpointStateRestoreTest::testSetState should be
fail
This case should be fail because three `KeyGroupStateHandles` which have
same `KeyGroupRange[0,0]` are received by `Che
