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