Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

HadoopDruidIndexerJob: Fix NPE

This commit is contained in:
Gian Merlino 2013-05-17 11:08:39 -07:00
parent 7d34710edf
commit b420892dd9
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
indexer/src/main/java/com/metamx/druid/indexer/HadoopDruidIndexerJob.java
View File

@ -102,6 +102,10 @@ public class HadoopDruidIndexerJob implements Jobby
} }
} }
if (failedMessage == null) {
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();
@ -119,8 +123,6 @@ public class HadoopDruidIndexerJob implements Jobby
throw new ISE(failedMessage); throw new ISE(failedMessage);
} }
publishedSegments = IndexGeneratorJob.getPublishedSegments(config);
return true; return true;
} }