Internal: PlainTransportFuture should not set currentThread().interrupt()
We use PlainTransportFuture as a future for our transport calls. If someone blocks on it and it is interrupted, we throw an ElasticsearchIllegalStateException. We should not set Thread.currentThread().interrupt(); in this case because we already communicate the interrupt through an exception. Closes #9001
This commit is contained in:
parent
d17db85794
commit
b9db5b178c
|
@ -62,7 +62,6 @@ public class PlainTransportFuture<V extends TransportResponse> extends BaseFutur
|
|||
} catch (TimeoutException e) {
|
||||
throw new ElasticsearchTimeoutException(e.getMessage());
|
||||
} catch (InterruptedException e) {
|
||||
Thread.currentThread().interrupt();
|
||||
throw new ElasticsearchIllegalStateException("Future got interrupted", e);
|
||||
} catch (ExecutionException e) {
|
||||
if (e.getCause() instanceof ElasticsearchException) {
|
||||
|
|
Loading…
Reference in New Issue