kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ted Yu (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-6531) SocketServerTest#closingChannelException fails sometimes
Date Mon, 16 Apr 2018 01:47:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Ted Yu resolved KAFKA-6531.
---------------------------
    Resolution: Cannot Reproduce

> SocketServerTest#closingChannelException fails sometimes
> --------------------------------------------------------
>
>                 Key: KAFKA-6531
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6531
>             Project: Kafka
>          Issue Type: Test
>          Components: core
>            Reporter: Ted Yu
>            Priority: Minor
>
> From https://builds.apache.org/job/kafka-trunk-jdk9/361/testReport/junit/kafka.network/SocketServerTest/closingChannelException/
:
> {code}
> java.lang.AssertionError: Channels not removed
> 	at kafka.utils.TestUtils$.fail(TestUtils.scala:355)
> 	at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:865)
> 	at kafka.network.SocketServerTest.assertProcessorHealthy(SocketServerTest.scala:914)
> 	at kafka.network.SocketServerTest.$anonfun$closingChannelException$1(SocketServerTest.scala:763)
> 	at kafka.network.SocketServerTest.$anonfun$closingChannelException$1$adapted(SocketServerTest.scala:747)
> {code}
> Among the test output, I saw:
> {code}
> [2018-02-04 18:51:15,995] ERROR Processor 0 closed connection from /127.0.0.1:48261 (kafka.network.SocketServerTest$$anon$5$$anon$1:73)
> java.lang.IllegalStateException: There is already a connection for id 127.0.0.1:1-127.0.0.1:2-0
> 	at org.apache.kafka.common.network.Selector.ensureNotRegistered(Selector.java:260)
> 	at org.apache.kafka.common.network.Selector.register(Selector.java:254)
> 	at kafka.network.SocketServerTest$TestableSelector.super$register(SocketServerTest.scala:1043)
> 	at kafka.network.SocketServerTest$TestableSelector.$anonfun$register$2(SocketServerTest.scala:1043)
> 	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
> 	at kafka.network.SocketServerTest$TestableSelector.runOp(SocketServerTest.scala:1037)
> 	at kafka.network.SocketServerTest$TestableSelector.register(SocketServerTest.scala:1043)
> 	at kafka.network.Processor.configureNewConnections(SocketServer.scala:723)
> 	at kafka.network.Processor.run(SocketServer.scala:532)
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message