amaechler opened a new pull request, #19580:
URL: https://github.com/apache/druid/pull/19580

   ### Description
   
   `KafkaIndexFaultToleranceTest` intermittently fails in CI with:
   
   ```
   org.apache.druid.java.util.common.ISE: Timed out waiting for event after 
[60,000]ms
       at org.apache.druid.server.metrics.LatchableEmitter.waitForEventAggregate
       at 
org.apache.druid.testing.embedded.indexing.StreamIndexTestBase.waitUntilPublishedRecordsAreIngested
   ```
   
   This PR increases the `LatchableEmitter` timeout to 120s from 60s identical 
to what `KinesisFaultToleranceTest` was already doing (but hoisted to the 
parent so both test classes inherit it now), so hopefully these tests finish.
   
   An alternative to "fail if total elapsed > 120s", an interesting refactor 
could be to instead "fail if no _new_ matching event for X seconds", something 
like that.
   
   <hr>
   
   This PR has:
   
   - [x] been self-reviewed.
   


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

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to