Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-20 00:47:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix flaky test method in KafkaSupervisorTest (#13315)

Browse Source
This commit is contained in:
AmatyaAvadhanula 2022-11-05 10:31:40 +05:30 committed by GitHub
parent d8329195f7
commit a17ffdfc5d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
View File

@ -4054,6 +4054,8 @@ public class KafkaSupervisorTest extends EasyMockSupport
supervisor.start(); supervisor.start();
supervisor.runInternal(); supervisor.runInternal();
Thread.sleep(1000);
Assert.assertEquals(failsToResumePausedTask.getId(), shutdownTaskId.getValue()); Assert.assertEquals(failsToResumePausedTask.getId(), shutdownTaskId.getValue());
verifyAll(); verifyAll();