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