becketqin commented on pull request #11856: URL: https://github.com/apache/flink/pull/11856#issuecomment-619655010
> The fact that this Interruption-based flow is hard to get right looks like it is at least part of the reason for the original bug, so I think it is worth thinking about. The interruption could happen in two cases: 1. Thrown from `SplitFetcher.wakeup();` 2. Thrown from `BlockingQueue.put()` in `FetchTask.run()`; There isn't much we can do in the first case, but we can probably have an implementation of `BlockingQueue` (just like the handover you mentioned) to avoid `InterruptedException` on `put()` in the second case. ---------------------------------------------------------------- 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]
