curcur commented on pull request #15420: URL: https://github.com/apache/flink/pull/15420#issuecomment-867330872
I think I've made similar comments and asked similar questions before, now I've forgotten it again, LOL; so it either worth making it POJO or at leave a comment. **Need to discuss offline** 1. In `ChangelogStateHandleStreamImpl`, what is `List<Tuple2<StreamStateHandle, Long>> handlesAndOffsets`, what is the offset? and there is an additional added field `size` 2. who will call "registerSharedStates", How is `SharedStateRegistry` related to the JM owned shared counter in the current model? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
