[incubator-druid] branch master updated: Fix assertionError at testCheckpointForInactiveTaskGroup in KafkaSupervisorTest (#6192)

[jihoonson]

This is an automated email from the ASF dual-hosted git repository.

jihoonson pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git


The following commit(s) were added to refs/heads/master by this push:
     new 7d4b2d5  Fix assertionError at testCheckpointForInactiveTaskGroup in 
KafkaSupervisorTest (#6192)
7d4b2d5 is described below

commit 7d4b2d51e8332f4fe139a9ca47bd61ff9a1c2fe2
Author: Benedict Jin <1571805...@qq.com>
AuthorDate: Wed Aug 22 02:33:45 2018 +0800

    Fix assertionError at testCheckpointForInactiveTaskGroup in 
KafkaSupervisorTest (#6192)
---
 .../java/io/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
 
b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
index 83e253f..4d062d8 100644
--- 
a/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
+++ 
b/extensions-core/kafka-indexing-service/src/test/java/io/druid/indexing/kafka/supervisor/KafkaSupervisorTest.java
@@ -2115,6 +2115,10 @@ public class KafkaSupervisorTest extends EasyMockSupport
 
     verifyAll();
 
+    while (serviceEmitter.getStackTrace() != null) {
+      Thread.sleep(100);
+    }
+
     Assert.assertNull(serviceEmitter.getStackTrace());
     Assert.assertNull(serviceEmitter.getExceptionMessage());
     Assert.assertNull(serviceEmitter.getExceptionClass());


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@druid.apache.org
For additional commands, e-mail: commits-h...@druid.apache.org