pnowojski edited a comment on pull request #17238: URL: https://github.com/apache/flink/pull/17238#issuecomment-921532855
1. I think technically it knows if upstream is ready or not, because retrying logic is on the downstream's `RemoteInputChannel`. 2. But in my idea downstream doesn't necessarily needs to explicitly know if the new buffer size announcement worked or not. If we can assume that the only way how new buffer size announcement can be overtaken by a partition request is if previous partition request failed and we are re-trying, then we can just cache the latest buffer size in the `RemoteInputChannel` and attach it to the `PartitionRequest` retry message. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
