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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
