[GitHub] [kafka] vvcephei commented on pull request #8884: MINOR: Fix flaky HighAvailabilityTaskAssignorIntegrationTest

[GitBox <gi...@apache.org>]

vvcephei commented on pull request #8884:
URL: https://github.com/apache/kafka/pull/8884#issuecomment-645008967


   Hey @ableegoldman or @cadonna , do you have a chance to look at this?
   
   Some Jenkins builds have failed like this:
   ```
   java.lang.AssertionError: Condition not met within timeout 120000. Input records haven't all been written to the changelog: 775
   	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26)
   	at org.apache.kafka.test.TestUtils.lambda$waitForCondition$6(TestUtils.java:401)
   	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:449)
   	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:417)
   	at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:398)
   	at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasks(HighAvailabilityTaskAssignorIntegrationTest.java:163)
   	at org.apache.kafka.streams.integration.HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores(HighAvailabilityTaskAssignorIntegrationTest.java:91)
   ```


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org