tzulitai commented on issue #30: [FLINK-16226] Add Backpressure to HttpFunction URL: https://github.com/apache/flink-statefun/pull/30#issuecomment-589940086 Thanks for the explanation. I think the field comment on `requestState` is pretty clear as is; I simply missed the fact that the value `0` has a special meaning in this case (which is also stated quite clearly already). So, from my understanding, the semantics are: - Backpressure occurs once local buffer for a given address hits `maxBatchSize` - The max pending requests, would be `2 * maxBatchSize` (`maxBatchSize` accumulated in local buffer state, and another `maxBatchSize` that is in-flight as a single request) 👌 I think that's good.
---------------------------------------------------------------- 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] With regards, Apache Git Services
