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 ` `.
---