[7.16] Prevent NullPointerException in SourceConfirmedTextQuery (#80472) (#80476)

* Prevent NullPointerException in SourceConfirmedTextQuery (#80472)

Prevents a npe when the field that does not exists in the index

* Prevent NullPointerException in SourceConfirmedTextQuery

Author: iverase

modules/mapper-extras/src/main/java/org/elasticsearch/index/query/SourceConfirmedTextQuery.java

@@ -214,28 +214,35 @@ public Weight createWeight(IndexSearcher searcher, ScoreMode scoreMode, float bo
             throw new IllegalStateException("Query " + in + " doesn't have any term");
         }
         final String field = terms.iterator().next().field();
-        final Map<Term, TermStates> termStates = new HashMap<>();
-        final List<TermStatistics> termStats = new ArrayList<>();
-        for (Term term : terms) {
-            TermStates ts = termStates.computeIfAbsent(term, t -> {
-                try {
-                    return TermStates.build(searcher.getTopReaderContext(), t, scoreMode.needsScores());
-                } catch (IOException e) {
-                    throw new UncheckedIOException(e);
-                }
-            });
-            if (scoreMode.needsScores()) {
-                if (ts.docFreq() > 0) {
-                    termStats.add(searcher.termStatistics(term, ts.docFreq(), ts.totalTermFreq()));
+        final CollectionStatistics collectionStatistics = searcher.collectionStatistics(field);
+        final SimScorer simScorer;
+        final Weight approximationWeight;
+        if (collectionStatistics == null) {
+            // field does not exist in the index
+            simScorer = null;
+            approximationWeight = null;
+        } else {
+            final Map<Term, TermStates> termStates = new HashMap<>();
+            final List<TermStatistics> termStats = new ArrayList<>();
+            for (Term term : terms) {
+                TermStates ts = termStates.computeIfAbsent(term, t -> {
+                    try {
+                        return TermStates.build(searcher.getTopReaderContext(), t, scoreMode.needsScores());
+                    } catch (IOException e) {
+                        throw new UncheckedIOException(e);
+                    }
+                });
+                if (scoreMode.needsScores()) {
+                    if (ts.docFreq() > 0) {
+                        termStats.add(searcher.termStatistics(term, ts.docFreq(), ts.totalTermFreq()));
+                    }
+                } else {
+                    termStats.add(new TermStatistics(term.bytes(), 1, 1L));
                 }
-            } else {
-                termStats.add(new TermStatistics(term.bytes(), 1, 1L));
             }
+            simScorer = searcher.getSimilarity().scorer(boost, collectionStatistics, termStats.toArray(new TermStatistics[0]));
+            approximationWeight = searcher.createWeight(approximate(in), ScoreMode.COMPLETE_NO_SCORES, 1f);
         }
-        final SimScorer simScorer = searcher.getSimilarity()
-            .scorer(boost, searcher.collectionStatistics(field), termStats.toArray(new TermStatistics[0]));
-        final Weight approximationWeight = searcher.createWeight(approximate(in), ScoreMode.COMPLETE_NO_SCORES, 1f);
-
         return new Weight(this) {
 
             @Override
@@ -272,7 +279,7 @@ public Explanation explain(LeafReaderContext context, int doc) throws IOExceptio
 
             @Override
             public RuntimePhraseScorer scorer(LeafReaderContext context) throws IOException {
-                final Scorer approximationScorer = approximationWeight.scorer(context);
+                final Scorer approximationScorer = approximationWeight != null ? approximationWeight.scorer(context) : null;
                 if (approximationScorer == null) {
                     return null;
                 }

modules/mapper-extras/src/test/java/org/elasticsearch/index/query/SourceConfirmedTextQueryTests.java

@@ -417,4 +417,15 @@ public void testApproximation() {
         ).build();
         assertEquals(approximation, SourceConfirmedTextQuery.approximate(phrasePrefixQuery));
     }
+
+    public void testEmptyIndex() throws Exception {
+        try (Directory dir = newDirectory(); IndexWriter w = new IndexWriter(dir, newIndexWriterConfig(Lucene.STANDARD_ANALYZER))) {
+            try (IndexReader reader = DirectoryReader.open(w)) {
+                IndexSearcher searcher = new IndexSearcher(reader);
+                PhraseQuery query = new PhraseQuery("body", "a", "b");
+                Query sourceConfirmedPhraseQuery = new SourceConfirmedTextQuery(query, SOURCE_FETCHER_PROVIDER, Lucene.STANDARD_ANALYZER);
+                assertEquals(0, searcher.count(sourceConfirmedPhraseQuery));
+            }
+        }
+    }
 }