From a17ffdfc5d82c8cf60dfb91015f69142e427d76f Mon Sep 17 00:00:00 2001
From: AmatyaAvadhanula <amatya.avadhanula@imply.io>
Date: Sat, 5 Nov 2022 10:31:40 +0530
Subject: [PATCH]  Fix flaky test method in KafkaSupervisorTest (#13315)

---
 .../druid/indexing/kafka/supervisor/KafkaSupervisorTest.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
index e5f60db0059..bcb0c9ed1c9 100644
--- a/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
+++ b/extensions-core/kafka-indexing-service/src/test/java/org/apache/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
@@ -4054,6 +4054,8 @@ public class KafkaSupervisorTest extends EasyMockSupport
     supervisor.start();
     supervisor.runInternal();
 
+    Thread.sleep(1000);
+
     Assert.assertEquals(failsToResumePausedTask.getId(), shutdownTaskId.getValue());
 
     verifyAll();