fixed various small comments

This commit is contained in:
Martijn van Groningen 2016-01-20 15:44:32 +01:00
parent 7aeb360932
commit 977bbaba02
3 changed files with 8 additions and 5 deletions

View File

@ -77,7 +77,7 @@ public class CompoundProcessor implements Processor {
} else {
executeOnFailure(ingestDocument, e, processor.getType());
}
return;
break;
}
}
}

View File

@ -19,6 +19,7 @@
package org.elasticsearch.ingest.processor;
import org.elasticsearch.ExceptionsHelper;
import org.elasticsearch.ingest.core.AbstractProcessorFactory;
import org.elasticsearch.ingest.core.IngestDocument;
import org.elasticsearch.ingest.core.ConfigurationUtils;
@ -78,9 +79,9 @@ public final class DateProcessor implements Processor {
for (Function<String, DateTime> dateParser : dateParsers) {
try {
dateTime = dateParser.apply(value);
} catch(Exception e) {
//try the next parser and keep track of the last exception
lastException = e;
} catch (Exception e) {
//try the next parser and keep track of the exceptions
lastException = ExceptionsHelper.useOrSuppress(lastException, e);
}
}

View File

@ -91,7 +91,9 @@ public class DeDotProcessor implements Processor {
} else if (obj instanceof List) {
@SuppressWarnings("unchecked")
List<Object> list = (List) obj;
list.forEach(this::deDot);
for (Object value : list) {
deDot(value);
}
}
}