Github user sihuazhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/6196#discussion_r197330813
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java
---
@@ -48,7 +48,8 @@
KeyedStateBackend<K>,
Snapshotable<SnapshotResult<KeyedStateHandle>,
Collection<KeyedStateHandle>>,
Closeable,
- CheckpointListener {
+ CheckpointListener,
+ KeyedStateFactory{
--- End diff --
I think this seems to miss a space ` `.---
