[ 
https://issues.apache.org/jira/browse/KAFKA-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14357640#comment-14357640
 ] 

Guozhang Wang commented on KAFKA-1501:
--------------------------------------

Thanks for the patch [~ewencp]. I have started to look at your patch but want 
to get some clarifications: 

TestUtils.choosePorts should return a random port number each time it gets 
called, but then since the socket is closed, the next time it gets called, the 
same port number could be returned before it gets used, hence causing the 
conflict?

> 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, KAFKA-1501.patch, 
> KAFKA-1501_2015-03-09_11:41:07.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)

Reply via email to