Jaikiran,
I can't reproduce the failure of the ProdcuerFailureHandlingTest.
I ran the single test . you probably are seeing some errors
written to console when you use ./gradlew -i -Dsingle.test .
These errors are expected in some unit tests as some of these
test failure cases.
If you can reproduce this or even intermittent test failure can you
please open up a new JIRA and attach your patch there.
Your review patch is attached KAFKA-1867 which is a different issue.
Thanks,
Harsha
On Sun, Jan 18, 2015, at 07:16 AM, Jaikiran Pai wrote:
> I could reproduce this consistently when that test *method* is run
> individually. From what I could gather, the __consumer_offset topic
> (being accessed in that test) had 50 partitions (default) which took a
> while for each of them to be assigned a leader and do other
> initialization and that timed out the metadata update wait during the
> producer.send. I increased the metadata fetch timeout specifically for
> that producer in that test method and was able to get past this. I've
> sent a patch here https://reviews.apache.org/r/30013/
>
>
> -Jaikiran
>
> On Sunday 18 January 2015 12:30 AM, Manikumar Reddy wrote:
> > I am consistently getting these errors. May be transient errors.
> >
> > On Sun, Jan 18, 2015 at 12:05 AM, Harsha <ka...@harsha.io> wrote:
> >
> >> I don't see any failures in tests with the latest trunk or 0.8.2. I ran
> >> it few times in a loop.
> >> -Harsha
> >>
> >> On Sat, Jan 17, 2015, at 08:38 AM, Manikumar Reddy wrote:
> >>> ProducerFailureHandlingTest.testCannotSendToInternalTopic is failing on
> >>> both 0.8.2 and trunk.
> >>>
> >>> Error on 0.8.2:
> >>> kafka.api.ProducerFailureHandlingTest > testCannotSendToInternalTopic
> >>> FAILED
> >>> java.util.concurrent.ExecutionException:
> >>> org.apache.kafka.common.errors.TimeoutException: Failed to update
> >>> metadata
> >>> after 3000 ms.
> >>> at
> >>>
> >> org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:437)
> >>> at
> >>>
> >> org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:352)
> >>> at
> >>>
> >> org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:248)
> >>> at
> >>>
> >> kafka.api.ProducerFailureHandlingTest.testCannotSendToInternalTopic(ProducerFailureHandlingTest.scala:309)
> >>> Caused by:
> >>> org.apache.kafka.common.errors.TimeoutException: Failed to update
> >>> metadata after 3000 ms.
> >>>
> >>>
> >>> Error on Trunk:
> >>> kafka.api.test.ProducerFailureHandlingTest >
> >>> testCannotSendToInternalTopic
> >>> FAILED
> >>> java.lang.AssertionError: null
> >>> at org.junit.Assert.fail(Assert.java:69)
> >>> at org.junit.Assert.assertTrue(Assert.java:32)
> >>> at org.junit.Assert.assertTrue(Assert.java:41)
> >>> at
> >>>
> >> kafka.api.test.ProducerFailureHandlingTest.testCannotSendToInternalTopic(ProducerFailureHandlingTest.scala:312)
> >>
>
