igalshilman opened a new pull request #29: [FLINK-16063] Add simple backpressure URL: https://github.com/apache/flink-statefun/pull/29 # WIP - This PR adds a simple backpressure mechanism. There are two ways that a backpressure can be triggered: 1. When the number of asynchronous operations per task exceeds a predefined threshold[1] 2. When a prebuilt internal function requires to backpressure a specific address[2] via calling an internal method on `ReusableContext`. Please note that, currently if a single function instance requires backpressure, then the result is that all other functions scheduled into the same operator are blocked. [1] currently that threshold is disabled, and it would be wired in once #27 would be merged. [2] Although the API allows blocking for a specific address, in the current implementation all the input (for all the addresses) would be blocked.
---------------------------------------------------------------- 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
