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; }