Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5691#discussion_r174381475
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/query/KvStateRegistry.java
---
@@ -136,13 +138,13 @@ public void unregisterKvState(
}
/**
- * Returns the KvState instance identified by the given KvStateID or
- * <code>null</code> if none is registered.
+ * Returns the KvState instance identified by the given KvStateID along
with
--- End diff --
would rephrase to `KvStateEntry` containing the `KvState`
---
