mirror of
https://github.com/apache/druid.git
synced 2025-02-17 23:46:30 +00:00
* BaseWorkerClientImpl: Don't attempt to recover from a closed channel. This patch introduces an exception type "ChannelClosedForWritesException", which allows the BaseWorkerClientImpl to avoid retrying when the local channel has been closed. This can happen in cases of cancellation. * Add some test coverage. * wip * Add test coverage. * Style. (cherry picked from commit 4dc5942dabacfc9e458f9c742e510cb94c091c8d)