diff options
| author | Martijn van Groningen <martijn.v.groningen@gmail.com> | 2016-05-31 11:58:20 +0200 |
|---|---|---|
| committer | Martijn van Groningen <martijn.v.groningen@gmail.com> | 2016-06-01 10:29:12 +0200 |
| commit | 766789b0f090915ec687c52cc832d9e45339a042 (patch) | |
| tree | 9d1e271b6843e440c80d4618c805180a2fcc6bcd /core/src/test/java/org/elasticsearch/action/ingest | |
| parent | 966bfc3f2da795c771e07359aa0547dabedcacfd (diff) | |
ingest: added `ignore_failure` option to all processors
If this option is enabled on a processor it silently catches any processor related failure and continues executing the rest of the pipeline.
Closes #18493
Diffstat (limited to 'core/src/test/java/org/elasticsearch/action/ingest')
| -rw-r--r-- | core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java b/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java index 30c29f8db5..f7f2f0212d 100644 --- a/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java +++ b/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java @@ -128,7 +128,7 @@ public class SimulateExecutionServiceTests extends ESTestCase { TestProcessor processor2 = new TestProcessor("processor_1", "mock", ingestDocument -> {}); TestProcessor processor3 = new TestProcessor("processor_2", "mock", ingestDocument -> {}); Pipeline pipeline = new Pipeline("_id", "_description", - new CompoundProcessor(new CompoundProcessor(Collections.singletonList(processor1), + new CompoundProcessor(new CompoundProcessor(false, Collections.singletonList(processor1), Collections.singletonList(processor2)), processor3)); SimulateDocumentResult actualItemResponse = executionService.executeDocument(pipeline, ingestDocument, true); assertThat(processor1.getInvokedCounter(), equalTo(1)); |