HadoopDruidIndexerJob: Correct error message when jobs fail

This commit is contained in:
Gian Merlino 2013-05-09 15:02:10 -07:00
parent bec5d248f0
commit 3e3f2c2da7
1 changed files with 2 additions and 2 deletions

View File

@ -102,8 +102,6 @@ public class HadoopDruidIndexerJob implements Jobby
} }
} }
publishedSegments = IndexGeneratorJob.getPublishedSegments(config);
if (!config.isLeaveIntermediate()) { if (!config.isLeaveIntermediate()) {
if (failedMessage == null || config.isCleanupOnFailure()) { if (failedMessage == null || config.isCleanupOnFailure()) {
Path workingPath = config.makeIntermediatePath(); Path workingPath = config.makeIntermediatePath();
@ -121,6 +119,8 @@ public class HadoopDruidIndexerJob implements Jobby
throw new ISE(failedMessage); throw new ISE(failedMessage);
} }
publishedSegments = IndexGeneratorJob.getPublishedSegments(config);
return true; return true;
} }