[GitHub] [kafka] guozhangwang commented on pull request #8600: KAFKA-9928: Fix flaky GlobalKTableEOSIntegrationTest

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

guozhangwang commented on pull request #8600:
URL: https://github.com/apache/kafka/pull/8600#issuecomment-624284868


   I still see the following issue locally:
   
   ```
   java.lang.AssertionError: Condition not met within timeout 30000. waiting for final values
     expected: {a=1+F, b=2+G, c=3+H, d=4+I, e=5+J}
     received: {a=1+A, b=2+G, c=3+H, d=4+I, e=5+J}
   
   	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:26)
   	at org.apache.kafka.test.TestUtils.lambda$waitForCondition$17(TestUtils.java:381)
   	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:429)
   	at org.apache.kafka.test.TestUtils.retryOnExceptionWithTimeout(TestUtils.java:397)
   	at org.apache.kafka.test.TestUtils.waitForCondition(TestUtils.java:378)
   	at org.apache.kafka.streams.integration.GlobalKTableEOSIntegrationTest.shouldKStreamGlobalKTableLeftJoin(GlobalKTableEOSIntegrationTest.java:205)
   ```
   
   In addition, sometimes the test will hang as well (i.e. the above verification would not fail, the test just runs forever); I tried using different assignor via `INTERNAL_TASK_ASSIGNOR_CLASS` but the same hanging issue still exists.


----------------------------------------------------------------
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