[KAFKA-6531] SocketServerTest#closingChannelException fails sometimes

• Type: Test
• Status: Resolved
• Priority: Minor
• Resolution: Cannot Reproduce
• Component/s: core
• Assignee: Unassigned
• Reporter: Ted Yu
• Created: 04/Feb/18 18:59
• Updated: 16/Apr/18 01:46
• Resolved: 16/Apr/18 01:46

Description

From https://builds.apache.org/job/kafka-trunk-jdk9/361/testReport/junit/kafka.network/SocketServerTest/closingChannelException/ :

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)

Among the test output, I saw:

[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)