diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java b/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java index f8a3b7be9b4..241679188e5 100644 --- a/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java +++ b/indexing-hadoop/src/main/java/io/druid/indexer/IndexGeneratorJob.java @@ -69,6 +69,7 @@ import org.joda.time.DateTime; import org.joda.time.Interval; import java.io.File; +import java.io.FileNotFoundException; import java.io.IOException; import java.nio.ByteBuffer; import java.util.Iterator; @@ -99,6 +100,14 @@ public class IndexGeneratorJob implements Jobby log.info("Adding segment %s to the list of published segments", segment.getIdentifier()); } } + catch (FileNotFoundException e) { + log.error( + "[%s] SegmentDescriptorInfo is not found usually when indexing process did not produce any segments meaning" + + " either there was no input data to process or all the input events were discarded due to some error", + e.getMessage() + ); + Throwables.propagate(e); + } catch (IOException e) { throw Throwables.propagate(e); }