Sending an index name to DocumentParsingObserver that is not ever null

masseyke · Oct 13, 2023 · 0da821d · 0da821d
1 parent 17ef0af
commit 0da821d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/server/src/main/java/org/elasticsearch/ingest/IngestService.java b/server/src/main/java/org/elasticsearch/ingest/IngestService.java
@@ -722,7 +722,8 @@ public void onFailure(Exception e) {
                         executePipelines(pipelines, indexRequest, ingestDocument, documentListener);
                         indexRequest.setPipelinesHaveRun();
 
-                        documentParsingObserver.setIndexName(indexRequest.index());
+                        assert actionRequest.index() != null;
+                        documentParsingObserver.setIndexName(actionRequest.index());
                         documentParsingObserver.close();
 
                         i++;