summaryrefslogtreecommitdiff
path: root/core/src/test/java/org/elasticsearch/action/ingest
diff options
context:
space:
mode:
authorTal Levy <JubBoy333@gmail.com>2016-05-24 14:25:40 -0700
committerTal Levy <JubBoy333@gmail.com>2016-05-24 14:25:40 -0700
commit0fa67e1538e189ff1b6b46c602ccf0cc6ff22bd1 (patch)
tree9fb95c0c7ac3d5037b5301ae721255fbe67f5b97 /core/src/test/java/org/elasticsearch/action/ingest
parent84dfa360b14c0809a236df0601d7a47b5aa4598f (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.java6
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"));
}
}