Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168528716
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/state/TaskStateManagerImplTest.java
---
@@ -109,10 +111,10 @@ public void testStateReportingAndRetrieving() {
executionAttemptID,
checkpointResponderMock,
taskRestore);
-
- Assert.assertTrue(jmOperatorSubtaskState_1 ==
taskStateManager.operatorStates(operatorID_1));
- Assert.assertTrue(jmOperatorSubtaskState_2 ==
taskStateManager.operatorStates(operatorID_2));
-
Assert.assertNull(taskStateManager.operatorStates(operatorID_3));
+//TODO
+// Assert.assertTrue(jmOperatorSubtaskState_1 ==
taskStateManager.prioritizedOperatorState(operatorID_1));
+// Assert.assertTrue(jmOperatorSubtaskState_2 ==
taskStateManager.prioritizedOperatorState(operatorID_2));
--- End diff --
Fixed in later commit.
---
