diff --git a/docs/content/Batch-ingestion.md b/docs/content/Batch-ingestion.md index 309d4d3ea32..2f3ee9821d7 100644 --- a/docs/content/Batch-ingestion.md +++ b/docs/content/Batch-ingestion.md @@ -202,7 +202,7 @@ The schema of the Hadoop Index Task contains a task "type" and a Hadoop Index Co "type" : "static", "paths" : "data.json" }, - "targetPartitionSize" : 5000000, + "targetPartitionSi:qze" : 5000000, "rollupSpec" : { "aggs": [{ "type" : "count", diff --git a/server/src/test/java/io/druid/client/client/BatchServerInventoryViewTest.java b/server/src/test/java/io/druid/client/client/BatchServerInventoryViewTest.java index 38864822eb8..a777222efe1 100644 --- a/server/src/test/java/io/druid/client/client/BatchServerInventoryViewTest.java +++ b/server/src/test/java/io/druid/client/client/BatchServerInventoryViewTest.java @@ -198,7 +198,8 @@ public class BatchServerInventoryViewTest private void waitForSync() throws Exception { Stopwatch stopwatch = new Stopwatch().start(); - while (Iterables.get(batchServerInventoryView.getInventory(), 0).getSegments().size() != testSegments.size()) { + while (!Iterables.isEmpty(batchServerInventoryView.getInventory()) + && Iterables.get(batchServerInventoryView.getInventory(), 0).getSegments().size() != testSegments.size()) { Thread.sleep(500); if (stopwatch.elapsed(TimeUnit.MILLISECONDS) > 5000) { throw new ISE("BatchServerInventoryView is not updating");