for each iter

elastic · Jun 30, 2019 · 0103761 · 0103761
1 parent f404843
commit 0103761
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/modules/ingest-common/src/main/java/org/elasticsearch/ingest/common/ForEachProcessor.java b/modules/ingest-common/src/main/java/org/elasticsearch/ingest/common/ForEachProcessor.java
@@ -94,13 +94,11 @@ void innerExecute(int index, List<?> values, List<Object> newValues, IngestDocum
             if (e != null)  {
                 newValues.add(document.getIngestMetadata().put("_value", previousValue));
                 handler.accept(null, e);
+            } else if (result == null) {
+                handler.accept(null, null);
             } else {
-                if (result == null) {
-                    handler.accept(null, null);
-                } else {
-                    newValues.add(document.getIngestMetadata().put("_value", previousValue));
-                    innerExecute(index + 1, values, newValues, document, handler);
-                }
+                newValues.add(document.getIngestMetadata().put("_value", previousValue));
+                innerExecute(index + 1, values, newValues, document, handler);
             }
         });
     }