diff --git a/resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolverContext.java b/resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolverContext.java index 6ca2801d0d..0e193f7534 100644 --- a/resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolverContext.java +++ b/resolver-dns/src/main/java/io/netty/resolver/dns/DnsNameResolverContext.java @@ -133,7 +133,7 @@ abstract class DnsNameResolverContext { public void operationComplete(Future> future) { queriesInProgress.remove(future); - if (promise.isDone()) { + if (promise.isDone() || future.isCancelled()) { return; }