diff --git a/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/xpack/security/transport/netty4/SecurityNetty4TransportCloseNotifyIT.java b/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/xpack/security/transport/netty4/SecurityNetty4TransportCloseNotifyIT.java index b949d3ea8371a..109effaeb0207 100644 --- a/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/xpack/security/transport/netty4/SecurityNetty4TransportCloseNotifyIT.java +++ b/x-pack/plugin/security/src/internalClusterTest/java/org/elasticsearch/xpack/security/transport/netty4/SecurityNetty4TransportCloseNotifyIT.java @@ -36,6 +36,7 @@ import java.util.Collection; import java.util.concurrent.CountDownLatch; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Consumer; @@ -121,7 +122,7 @@ public void testSendCloseNotifyAfterHttpGetRequests() throws Exception { channel.close().sync(); } } finally { - client.config().group().shutdownGracefully().sync(); + client.config().group().shutdownGracefully(0, 0, TimeUnit.SECONDS).sync(); } } @@ -150,7 +151,7 @@ public void testSendCloseNotifyCancelAction() throws Exception { channel.close().sync(); } } finally { - client.config().group().shutdownGracefully().sync(); + client.config().group().shutdownGracefully(0, 0, TimeUnit.SECONDS).sync(); } }