[ https://issues.apache.org/jira/browse/KAFKA-6531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ted Yu updated KAFKA-6531: -------------------------- Description: >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} was: >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} > 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)