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

Ewen Cheslack-Postava commented on KAFKA-1501:
----------------------------------------------

[~guozhang] Sorry, seems I missed your review comments on the last patch. I've 
addressed most of them and rebased to currrent trunk. Also had to make some 
changes to handle the consumer tests that were added back. And I restored the 
test I commented to use the previous port allocation strategy so we still get 
test coverage while minimizing (but not entirely eliminating) tests that can 
fail due to ports already in use.

We now have 2 places where we need fixed ports to properly handle tests -- 
bounce tests for the new producer and new consumer implementations. Both are 
integration tests that probably better to have in a separate integration tests 
framework. But until we have a better solution than the existing system test 
framework, it probably does make sense to fix the majority of tests. A few can 
still fail, but at least we'll have drastically reduced the probability of 
encountering this error.

> 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, KAFKA-1501_2015-03-25_00:44:50.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