rkhachatryan opened a new pull request #17258: URL: https://github.com/apache/flink/pull/17258
This is an alternative implementation of FLINK-23342: Sharing information about the state is encoded into the state handles (specifically,low-level state handles such as `FileStateHandle`) This information is passed between JM and TM in both directions and will be used in to decide whether to delete state or not. To accomplish this, `StateAssignmentOperation` computes shared state based on state IDs and rebuilds the snapshot before sending it to TM, marking the corresponding handles as shared. `SharedStateRegistry` is not affected by this change. cc: @StephanEwen -- 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. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
