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:
us...@infra.apache.org


Reply via email to