kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-2386) Transient test failure: testGenerationIdIncrementsOnRebalance
Date Mon, 03 Aug 2015 22:04:05 GMT

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

ASF GitHub Bot commented on KAFKA-2386:

GitHub user hachikuji opened a pull request:


    KAFKA-2386; increase timeouts for transient test failure in ConsumerCoordinatorResponseTests

    There are two race conditions in the test case "testGenerationIdIncrementsOnRebalance."
First, a delay before the second join group request can timeout the initial group and cause
the generationId to unexpectedly reset. Second, a delay in the join group request handling
will timeout the request itself and cause the test to fail.  This commit doesn't address these
race conditions, but increases the timeouts to make them more unlikely. If the problem reoccurs,
then we'll probably need a better solution.

You can merge this pull request into a Git repository by running:

    $ git pull https://github.com/hachikuji/kafka KAFKA-2386

Alternatively you can review and apply these changes as the patch at:


To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #107
commit a53460a1a6637a814cbfe3731431746e56c52742
Author: Jason Gustafson <jason@confluent.io>
Date:   2015-07-31T23:17:36Z

    KAFKA-2386; increase timeouts for transient test failure in ConsumerCoordinatorResponseTest


> Transient test failure: testGenerationIdIncrementsOnRebalance
> -------------------------------------------------------------
>                 Key: KAFKA-2386
>                 URL: https://issues.apache.org/jira/browse/KAFKA-2386
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Jason Gustafson
> Seen this in some builds. Might be caused by gc pause (or similar) which delays group
join in the test.
> {code}
> kafka.coordinator.ConsumerCoordinatorResponseTest > testGenerationIdIncrementsOnRebalance
>     java.util.concurrent.TimeoutException: Futures timed out after [40 milliseconds]
>         at scala.concurrent.impl.Promise$DefaultPromise.ready(Promise.scala:219)
>         at scala.concurrent.impl.Promise$DefaultPromise.result(Promise.scala:223)
>         at scala.concurrent.Await$$anonfun$result$1.apply(package.scala:107)
>         at scala.concurrent.BlockContext$DefaultBlockContext$.blockOn(BlockContext.scala:53)
>         at scala.concurrent.Await$.result(package.scala:107)
>         at kafka.coordinator.ConsumerCoordinatorResponseTest.joinGroup(ConsumerCoordinatorResponseTest.scala:313)
>         at kafka.coordinator.ConsumerCoordinatorResponseTest.testGenerationIdIncrementsOnRebalance(ConsumerCoordinatorResponseTest.scala:272)
> {code}

This message was sent by Atlassian JIRA

View raw message