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

attempt to fix transient tests again

Browse Source
This commit is contained in:
fjy 2015-12-30 21:37:15 -08:00
parent b68265399c
commit ca46f1d40c
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
extensions/kafka-extraction-namespace/src/test/java/io/druid/query/extraction/namespace/TestKafkaExtractionCluster.java
View File

@ -408,15 +408,17 @@ public class TestKafkaExtractionCluster
) )
throws InterruptedException throws InterruptedException
{ {
final Function<String, String> extractionFn = lookup.get(namespace); Function<String, String> extractionFn = lookup.get(namespace);
if (expected == null) { if (expected == null) {
while (extractionFn.apply(key) != null) { while (extractionFn.apply(key) != null) {
Thread.sleep(100); Thread.sleep(100);
extractionFn = lookup.get(namespace);
} }
} else { } else {
while (!expected.equals(extractionFn.apply(key))) { while (!expected.equals(extractionFn.apply(key))) {
Thread.sleep(100); Thread.sleep(100);
extractionFn = lookup.get(namespace);
} }
} }
@ -431,10 +433,11 @@ public class TestKafkaExtractionCluster
) )
throws InterruptedException throws InterruptedException
{ {
final Function<String, List<String>> extractionFn = lookup.get(namespace); Function<String, List<String>> extractionFn = lookup.get(namespace);
while (!extractionFn.apply(key).equals(expected)) { while (!extractionFn.apply(key).equals(expected)) {
Thread.sleep(100); Thread.sleep(100);
extractionFn = lookup.get(namespace);
} }
Assert.assertEquals("update check", expected, extractionFn.apply(key)); Assert.assertEquals("update check", expected, extractionFn.apply(key));

1
extensions/namespace-lookup/src/test/java/io/druid/server/namespace/cache/JDBCExtractionNamespaceTest.java vendored
View File

@ -486,6 +486,7 @@ public class JDBCExtractionNamespaceTest
// rely on test timeout to break out of this loop // rely on test timeout to break out of this loop
while (!extractionFn.apply(key).equals(expected)) { while (!extractionFn.apply(key).equals(expected)) {
Thread.sleep(100); Thread.sleep(100);
extractionFn = fnCache.get(namespace);
} }
Assert.assertEquals( Assert.assertEquals(