diff --git a/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java b/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java index 040782968e7..d8663ade60b 100644 --- a/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java +++ b/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java @@ -85,6 +85,19 @@ public class IngestActionFilterTests extends ESTestCase { verifyZeroInteractions(executionService, actionFilterChain); } + public void testApplyBulkNoPipelineId() throws Exception { + BulkRequest bulkRequest = new BulkRequest(); + bulkRequest.add(new IndexRequest()); + Task task = mock(Task.class); + ActionListener actionListener = mock(ActionListener.class); + ActionFilterChain actionFilterChain = mock(ActionFilterChain.class); + + filter.apply(task, BulkAction.NAME, bulkRequest, actionListener, actionFilterChain); + + verify(actionFilterChain).proceed(task, BulkAction.NAME, bulkRequest, actionListener); + verifyZeroInteractions(executionService, actionFilterChain); + } + @SuppressWarnings("unchecked") public void testApplyIngestIdViaRequestParam() throws Exception { Task task = mock(Task.class);