kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] branch trunk updated: KAFKA-6741: Disable Selector's idle connection timeout in testNetworkThreadTimeRecorded() test (#4824)
Date Thu, 05 Apr 2018 13:56:31 GMT
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 77c79df  KAFKA-6741:  Disable Selector's idle connection timeout in testNetworkThreadTimeRecorded()
test (#4824)
77c79df is described below

commit 77c79df396ec232981829f2ed61c5484cc8f1722
Author: Manikumar Reddy O <manikumar.reddy@gmail.com>
AuthorDate: Thu Apr 5 19:26:27 2018 +0530

    KAFKA-6741:  Disable Selector's idle connection timeout in testNetworkThreadTimeRecorded()
test (#4824)
    
    Reviewers: Jason Gustafson <jason@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>
---
 .../java/org/apache/kafka/common/network/SslTransportLayerTest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
index f54f490..d6b4bac 100644
--- a/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
+++ b/clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
@@ -635,7 +635,7 @@ public class SslTransportLayerTest {
     @Test
     public void testNetworkThreadTimeRecorded() throws Exception {
         selector.close();
-        this.selector = new Selector(NetworkReceive.UNLIMITED, 5000, new Metrics(), Time.SYSTEM,
+        this.selector = new Selector(NetworkReceive.UNLIMITED, Selector.NO_IDLE_TIMEOUT_MS,
new Metrics(), Time.SYSTEM,
                 "MetricGroup", new HashMap<String, String>(), false, true, channelBuilder,
MemoryPool.NONE, new LogContext());
 
         String node = "0";

-- 
To stop receiving notification emails like this one, please contact
rsivaram@apache.org.

Mime
View raw message