[ https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14236040#comment-14236040 ]
Ewen Cheslack-Postava commented on KAFKA-1501: ---------------------------------------------- They've all been patched. I do notice that it's always failing on after a few tests within a suite, there's no particular test triggering it, and it happens for both ZK and Kafka nodes. The patch now allocates all the ports needed when the test class is instantiated and reuses them across individual tests. So now it looks more like a port is getting left in a state that doesn't allow it to be freed, i.e. something closer to the problem people originally thought it was. Unfortunately allocating ports separately for each test isn't easy because of the way the tests are currently structured (building configs during construction so setUp() can pull up the servers). > transient unit tests failures due to port already in use > -------------------------------------------------------- > > Key: KAFKA-1501 > URL: https://issues.apache.org/jira/browse/KAFKA-1501 > Project: Kafka > Issue Type: Improvement > Components: core > Reporter: Jun Rao > Assignee: Guozhang Wang > Labels: newbie > Attachments: KAFKA-1501-choosePorts.patch, KAFKA-1501.patch, > KAFKA-1501.patch, KAFKA-1501.patch, test-100.out, test-100.out, test-27.out, > test-29.out, test-32.out, test-35.out, test-38.out, test-4.out, test-42.out, > test-45.out, test-46.out, test-51.out, test-55.out, test-58.out, test-59.out, > test-60.out, test-69.out, test-72.out, test-74.out, test-76.out, test-84.out, > test-87.out, test-91.out, test-92.out > > > Saw the following transient failures. > kafka.api.ProducerFailureHandlingTest > testTooLargeRecordWithAckOne FAILED > kafka.common.KafkaException: Socket server failed to bind to > localhost:59909: Address already in use. > at kafka.network.Acceptor.openServerSocket(SocketServer.scala:195) > at kafka.network.Acceptor.<init>(SocketServer.scala:141) > at kafka.network.SocketServer.startup(SocketServer.scala:68) > at kafka.server.KafkaServer.startup(KafkaServer.scala:95) > at kafka.utils.TestUtils$.createServer(TestUtils.scala:123) > at > kafka.api.ProducerFailureHandlingTest.setUp(ProducerFailureHandlingTest.scala:68) -- This message was sent by Atlassian JIRA (v6.3.4#6332)