|
@@ -310,7 +310,8 @@ extends AMRMClientAsync<T> {
|
|
try {
|
|
try {
|
|
object = responseQueue.take();
|
|
object = responseQueue.take();
|
|
} catch (InterruptedException ex) {
|
|
} catch (InterruptedException ex) {
|
|
- LOG.info("Interrupted while waiting for queue", ex);
|
|
|
|
|
|
+ LOG.debug("Interrupted while waiting for queue", ex);
|
|
|
|
+ Thread.currentThread().interrupt();
|
|
continue;
|
|
continue;
|
|
}
|
|
}
|
|
if (object instanceof Throwable) {
|
|
if (object instanceof Throwable) {
|