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();
}