From bec5d248f04c83a0f00a26e582580c7500392191 Mon Sep 17 00:00:00 2001 From: xvrl Date: Wed, 8 May 2013 15:38:45 -0700 Subject: [PATCH 1/2] fix typo --- .../main/java/com/metamx/druid/client/ServerInventoryView.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/client/src/main/java/com/metamx/druid/client/ServerInventoryView.java b/client/src/main/java/com/metamx/druid/client/ServerInventoryView.java index b15b547a5f2..4c6b302ad46 100644 --- a/client/src/main/java/com/metamx/druid/client/ServerInventoryView.java +++ b/client/src/main/java/com/metamx/druid/client/ServerInventoryView.java @@ -135,7 +135,7 @@ public class ServerInventoryView implements ServerView, InventoryView @Override public void deadContainer(DruidServer deadContainer) { - log.info("Server Disdappeared[%s]", deadContainer); + log.info("Server Disappeared[%s]", deadContainer); runServerCallbacks(deadContainer); } From 3e3f2c2da7bcc7ae06cee1ac738f99654516c8cd Mon Sep 17 00:00:00 2001 From: Gian Merlino Date: Thu, 9 May 2013 15:02:10 -0700 Subject: [PATCH 2/2] HadoopDruidIndexerJob: Correct error message when jobs fail --- .../java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java b/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java index 8dad62cd2c6..f2f192fbeea 100644 --- a/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java +++ b/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java @@ -102,8 +102,6 @@ public class HadoopDruidIndexerJob implements Jobby } } - publishedSegments = IndexGeneratorJob.getPublishedSegments(config); - if (!config.isLeaveIntermediate()) { if (failedMessage == null || config.isCleanupOnFailure()) { Path workingPath = config.makeIntermediatePath(); @@ -121,6 +119,8 @@ public class HadoopDruidIndexerJob implements Jobby throw new ISE(failedMessage); } + publishedSegments = IndexGeneratorJob.getPublishedSegments(config); + return true; }