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 b1eb877205a..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,7 +102,7 @@ public class HadoopDruidIndexerJob implements Jobby } } - if (failedMessage != null) { + if (failedMessage == null) { publishedSegments = IndexGeneratorJob.getPublishedSegments(config); }