You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by GitBox <gi...@apache.org> on 2020/12/11 08:37:02 UTC
[GitHub] [flink-statefun] tzulitai opened a new pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes
tzulitai opened a new pull request #186:
URL: https://github.com/apache/flink-statefun/pull/186
This PR adds throttling to the `RequestReplyFunction`, to mitigate heavily loading remote functions on startup or restores where there is a large backlog of events to process through.
The change is rather simple: on receiving the first input for a given function type, dispatch the invocation as usual but block further inputs (by calling `context.awaitResponseIfNotBootstrapped`) until the request is complete.
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [flink-statefun] tzulitai closed pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes
Posted by GitBox <gi...@apache.org>.
tzulitai closed pull request #186:
URL: https://github.com/apache/flink-statefun/pull/186
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [flink-statefun] tzulitai commented on pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes
Posted by GitBox <gi...@apache.org>.
tzulitai commented on pull request #186:
URL: https://github.com/apache/flink-statefun/pull/186#issuecomment-749344193
Yes makes sense!
----------------------------------------------------------------
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:
users@infra.apache.org
[GitHub] [flink-statefun] igalshilman commented on pull request #186: [FLINK-20574] [core] Block further inputs until first invocation completes
Posted by GitBox <gi...@apache.org>.
igalshilman commented on pull request #186:
URL: https://github.com/apache/flink-statefun/pull/186#issuecomment-748908086
How about we'll close this PR for now?
----------------------------------------------------------------
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:
users@infra.apache.org