wsry commented on pull request #15199: URL: https://github.com/apache/flink/pull/15199#issuecomment-803275446
@zhuzhurk @gaoyunhaii Thanks for the review and comments. I have updated the PR by pushing a fixup commit. You can take a look. BTW, I removed the max buffers per requester logic in the fixup commit because the blocking wait occupies a thread which should be used by others. I will implement a similar logic at requester side. (A requester will not request new buffers if too many buffers are already allocated, only when total requested buffers are smaller than the threshold, the data read task will be resubmitted again) -- 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: us...@infra.apache.org
