Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5239#discussion_r168498124
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/TaskStateSnapshot.java
---
@@ -75,7 +79,10 @@ public OperatorSubtaskState
getSubtaskStateByOperatorID(OperatorID operatorID) {
* Maps the given operator id to the given subtask state. Returns the
subtask state of a previous mapping, if such
* a mapping existed or null otherwise.
*/
- public OperatorSubtaskState putSubtaskStateByOperatorID(OperatorID
operatorID, OperatorSubtaskState state) {
+ public OperatorSubtaskState putSubtaskStateByOperatorID(
--- End diff --
`@Nullable` missing.
---
