This is an automated email from the ASF dual-hosted git repository.

rsivaram pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new cb48466  MINOR: Fix Transient test failure 
SslTransportLayerTest.testNetworkThreadTimeRecorded (#5597)
cb48466 is described below

commit cb484666f2474747538585ed3b986aed5b02830d
Author: Manikumar Reddy O <[email protected]>
AuthorDate: Mon Sep 3 21:19:48 2018 +0530

    MINOR: Fix Transient test failure 
SslTransportLayerTest.testNetworkThreadTimeRecorded (#5597)
---
 .../src/test/java/org/apache/kafka/common/network/NioEchoServer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java 
b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
index bd212fd..7996e59 100644
--- a/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
+++ b/clients/src/test/java/org/apache/kafka/common/network/NioEchoServer.java
@@ -95,7 +95,7 @@ public class NioEchoServer extends Thread {
         if (channelBuilder == null)
             channelBuilder = 
ChannelBuilders.serverChannelBuilder(listenerName, false, securityProtocol, 
config, credentialCache, tokenCache);
         this.metrics = new Metrics();
-        this.selector = new Selector(5000, failedAuthenticationDelayMs, 
metrics, time, "MetricGroup", channelBuilder, new LogContext());
+        this.selector = new Selector(10000, failedAuthenticationDelayMs, 
metrics, time, "MetricGroup", channelBuilder, new LogContext());
         acceptorThread = new AcceptorThread();
     }
 

Reply via email to