[
https://issues.apache.org/jira/browse/KAFKA-6741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16426959#comment-16426959
]
ASF GitHub Bot commented on KAFKA-6741:
---------------------------------------
rajinisivaram closed pull request #4824: KAFKA-6741: Disable Selector's idle
connection timeout in testNetworkThreadTimeRecorded() test
URL: https://github.com/apache/kafka/pull/4824
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
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 f54f490ec0a..d6b4bac48d8 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 void testApplicationBufferResize() throws Exception {
@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";
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> Transient test failure: SslTransportLayerTest.testNetworkThreadTimeRecorded
> ---------------------------------------------------------------------------
>
> Key: KAFKA-6741
> URL: https://issues.apache.org/jira/browse/KAFKA-6741
> Project: Kafka
> Issue Type: Bug
> Reporter: Manikumar
> Priority: Minor
>
> debug logs:
> {code}
> [2018-04-03 14:51:33,365] DEBUG Added sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,368] DEBUG Added sensor with name connections-created:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,368] DEBUG Added sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,368] DEBUG Added sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,368] DEBUG Added sensor with name bytes-sent-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,369] DEBUG Added sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,370] DEBUG Added sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,370] DEBUG Added sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,371] DEBUG Added sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,379] DEBUG Removed sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,379] DEBUG Removed sensor with name
> connections-created: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,379] DEBUG Removed sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,380] DEBUG Removed sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,380] DEBUG Removed sensor with name
> bytes-sent-received: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,380] DEBUG Removed sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,380] DEBUG Removed sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,382] DEBUG Removed sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,382] DEBUG Removed sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:33,382] DEBUG Added sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,382] DEBUG Added sensor with name connections-created:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,383] DEBUG Added sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,383] DEBUG Added sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,383] DEBUG Added sensor with name bytes-sent-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,384] DEBUG Added sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,384] DEBUG Added sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,384] DEBUG Added sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,384] DEBUG Added sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,444] DEBUG Added sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,445] DEBUG Added sensor with name connections-created:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,445] DEBUG Added sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,445] DEBUG Added sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,446] DEBUG Added sensor with name bytes-sent-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,446] DEBUG Added sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,446] DEBUG Added sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,447] DEBUG Added sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,447] DEBUG Added sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,890] DEBUG Created socket with SO_RCVBUF = 326640,
> SO_SNDBUF = 65328, SO_TIMEOUT = 0 to node 0
> (org.apache.kafka.common.network.Selector:474)
> [2018-04-03 14:51:33,892] DEBUG Added sensor with name
> node-127.0.0.1:53543-127.0.0.1:53544.bytes-sent
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,893] DEBUG Added sensor with name
> node-127.0.0.1:53543-127.0.0.1:53544.bytes-received
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,893] DEBUG Added sensor with name
> node-127.0.0.1:53543-127.0.0.1:53544.latency
> (org.apache.kafka.common.metrics.Metrics:414)
> [2018-04-03 14:51:33,918] DEBUG [SslTransportLayer
> channelId=127.0.0.1:53543-127.0.0.1:53544
> key=sun.nio.ch.SelectionKeyImpl@6abde74] SSL peer is not authenticated,
> returning ANONYMOUS instead
> (org.apache.kafka.common.network.SslTransportLayer:714)
> [2018-04-03 14:51:33,918] DEBUG [SslTransportLayer channelId=0
> key=sun.nio.ch.SelectionKeyImpl@130f889] SSL handshake completed successfully
> with peerHost 'localhost' peerPort 53543 peerPrincipal 'O=A server,
> CN=server' cipherSuite 'TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256'
> (org.apache.kafka.common.network.SslTransportLayer:412)
> [2018-04-03 14:51:33,918] DEBUG [SslTransportLayer
> channelId=127.0.0.1:53543-127.0.0.1:53544
> key=sun.nio.ch.SelectionKeyImpl@6abde74] SSL handshake completed successfully
> with peerHost '127.0.0.1' peerPort 53544 peerPrincipal 'User:ANONYMOUS'
> cipherSuite 'TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256'
> (org.apache.kafka.common.network.SslTransportLayer:412)
> [2018-04-03 14:51:39,231] DEBUG Connection with /127.0.0.1 disconnected
> (org.apache.kafka.common.network.Selector:527)
> java.io.IOException: Broken pipe
> at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
> at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
> at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
> at sun.nio.ch.IOUtil.write(IOUtil.java:65)
> at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471)
> at
> org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:211)
> at
> org.apache.kafka.common.network.SslTransportLayer.write(SslTransportLayer.java:644)
> at
> org.apache.kafka.common.network.SslTransportLayer.write(SslTransportLayer.java:677)
> at
> org.apache.kafka.common.network.SslTransportLayer.write(SslTransportLayer.java:702)
> at
> org.apache.kafka.common.network.ByteBufferSend.writeTo(ByteBufferSend.java:60)
> at org.apache.kafka.common.network.KafkaChannel.send(KafkaChannel.java:239)
> at org.apache.kafka.common.network.KafkaChannel.write(KafkaChannel.java:210)
> at
> org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:509)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:424)
> at org.apache.kafka.common.network.NioEchoServer.run(NioEchoServer.java:145)
> [2018-04-03 14:51:39,234] WARN [SslTransportLayer
> channelId=127.0.0.1:53543-127.0.0.1:53544
> key=sun.nio.ch.SelectionKeyImpl@6abde74] Failed to send SSL Close message
> (org.apache.kafka.common.network.SslTransportLayer:177)
> java.io.IOException: Broken pipe
> at sun.nio.ch.FileDispatcherImpl.write0(Native Method)
> at sun.nio.ch.SocketDispatcher.write(SocketDispatcher.java:47)
> at sun.nio.ch.IOUtil.writeFromNativeBuffer(IOUtil.java:93)
> at sun.nio.ch.IOUtil.write(IOUtil.java:65)
> at sun.nio.ch.SocketChannelImpl.write(SocketChannelImpl.java:471)
> at
> org.apache.kafka.common.network.SslTransportLayer.flush(SslTransportLayer.java:211)
> at
> org.apache.kafka.common.network.SslTransportLayer.close(SslTransportLayer.java:161)
> at org.apache.kafka.common.utils.Utils.closeAll(Utils.java:723)
> at org.apache.kafka.common.network.KafkaChannel.close(KafkaChannel.java:61)
> at org.apache.kafka.common.network.Selector.doClose(Selector.java:746)
> at org.apache.kafka.common.network.Selector.close(Selector.java:734)
> at
> org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:532)
> at org.apache.kafka.common.network.Selector.poll(Selector.java:424)
> at org.apache.kafka.common.network.NioEchoServer.run(NioEchoServer.java:145)
> [2018-04-03 14:51:49,162] DEBUG Removed sensor with name connections-closed:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,163] DEBUG Removed sensor with name
> connections-created: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,163] DEBUG Removed sensor with name
> successful-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,163] DEBUG Removed sensor with name
> failed-authentication: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,163] DEBUG Removed sensor with name
> bytes-sent-received: (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,163] DEBUG Removed sensor with name bytes-sent:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,164] DEBUG Removed sensor with name bytes-received:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,164] DEBUG Removed sensor with name select-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> [2018-04-03 14:51:49,164] DEBUG Removed sensor with name io-time:
> (org.apache.kafka.common.metrics.Metrics:447)
> java.lang.AssertionError: Condition not met within timeout 15000. Timed out
> waiting for a message to receive from echo server
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:276)
> at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:254)
> at
> org.apache.kafka.common.network.SslTransportLayerTest.testNetworkThreadTimeRecorded(SslTransportLayerTest.java:665)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> at
> com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
> at
> com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:47)
> at
> com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
> at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
> Process finished with exit code 255
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
