diff options
author | Tal Levy <JubBoy333@gmail.com> | 2016-05-24 14:25:40 -0700 |
---|---|---|
committer | Tal Levy <JubBoy333@gmail.com> | 2016-05-24 14:25:40 -0700 |
commit | 0fa67e1538e189ff1b6b46c602ccf0cc6ff22bd1 (patch) | |
tree | 9fb95c0c7ac3d5037b5301ae721255fbe67f5b97 /core/src/test/java/org/elasticsearch/action/ingest | |
parent | 84dfa360b14c0809a236df0601d7a47b5aa4598f (diff) |
Expose underlying processor to blame for thrown exception within CompoundProcessor (#18342)
Fixes #17823
Diffstat (limited to 'core/src/test/java/org/elasticsearch/action/ingest')
-rw-r--r-- | core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java | 6 |
1 files changed, 4 insertions, 2 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 56e67bb4ad..30c29f8db5 100644 --- a/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java +++ b/core/src/test/java/org/elasticsearch/action/ingest/SimulateExecutionServiceTests.java @@ -19,6 +19,7 @@ package org.elasticsearch.action.ingest; +import org.elasticsearch.ElasticsearchException; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.ingest.RandomDocumentPicks; import org.elasticsearch.ingest.TestProcessor; @@ -167,7 +168,8 @@ public class SimulateExecutionServiceTests extends ESTestCase { SimulateDocumentBaseResult simulateDocumentBaseResult = (SimulateDocumentBaseResult) actualItemResponse; assertThat(simulateDocumentBaseResult.getIngestDocument(), nullValue()); assertThat(simulateDocumentBaseResult.getFailure(), instanceOf(RuntimeException.class)); - RuntimeException runtimeException = (RuntimeException) simulateDocumentBaseResult.getFailure(); - assertThat(runtimeException.getMessage(), equalTo("processor failed")); + Exception exception = simulateDocumentBaseResult.getFailure(); + assertThat(exception, instanceOf(ElasticsearchException.class)); + assertThat(exception.getMessage(), equalTo("java.lang.IllegalArgumentException: java.lang.RuntimeException: processor failed")); } } |