From b420892dd9dc038e5d695fa766228ece04bb16c3 Mon Sep 17 00:00:00 2001
From: Gian Merlino <gianmerlino@gmail.com>
Date: Fri, 17 May 2013 11:08:39 -0700
Subject: [PATCH] HadoopDruidIndexerJob: Fix NPE

---
 .../com/metamx/druid/indexer/HadoopDruidIndexerJob.java     | 6 ++++--
 1 file changed, 4 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 f2f192fbeea..d9dc0bb1e11 100644
--- a/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java
+++ b/indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java
@@ -102,6 +102,10 @@ public class HadoopDruidIndexerJob implements Jobby
       }
     }
 
+    if (failedMessage == null) {
+      publishedSegments = IndexGeneratorJob.getPublishedSegments(config);
+    }
+
     if (!config.isLeaveIntermediate()) {
       if (failedMessage == null || config.isCleanupOnFailure()) {
         Path workingPath = config.makeIntermediatePath();
@@ -119,8 +123,6 @@ public class HadoopDruidIndexerJob implements Jobby
       throw new ISE(failedMessage);
     }
 
-    publishedSegments = IndexGeneratorJob.getPublishedSegments(config);
-
     return true;
   }