StephanEwen opened a new pull request #13593:
URL: https://github.com/apache/flink/pull/13593
## What is the purpose of the change
Fixes two test instabilities on the `SplitFetcherTest`.
## Brief change log
The test logic was previously incorrect. This now adjusts the logic to
correctly reflect the requirements for idleness notifications, as required by
the reader, where at least one of the following conditions must be true:
- Either the fetcher was already set to idle when the reader thread pulled
the last fetch from the queue, because that is when the reader thread checks
for fetcher being idle and shuts it down (which signals end of input)
- Or the fetcher was not yet marked idle, because the fetch was pulled
before that flag was set. In that case, the availability future must be
completed, so that the reader thread goes back to checking the fetcher.
----------------------------------------------------------------
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]
