igalshilman opened a new pull request #208: URL: https://github.com/apache/flink-statefun/pull/208
According to the request-reply protocol, on recovery we re-send the uncompleted (in-flight during failure) messages. But we shouldn't assume that the state definitions are the same as in the previous attempt. We create a retry batch and let the SDK to reply with the correct state specs. see the JIRA issue with more details about the failure scenario ---------------------------------------------------------------- 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: [email protected]
