File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed 
server/src/main/java/org/elasticsearch/action/search Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change 5151import  org .elasticsearch .index .shard .ShardNotFoundException ;
5252import  org .elasticsearch .indices .ExecutorSelector ;
5353import  org .elasticsearch .indices .breaker .CircuitBreakerService ;
54- import  org .elasticsearch .search .SearchPhaseResult ;
5554import  org .elasticsearch .search .SearchService ;
5655import  org .elasticsearch .search .aggregations .AggregationReduceContext ;
5756import  org .elasticsearch .search .aggregations .InternalAggregations ;
@@ -1105,8 +1104,8 @@ public SearchPhase newSearchPhase(
11051104                    shardIterators .size (),
11061105                    exc  -> searchTransportService .cancelSearchTask (task , "failed to merge result ["  + exc .getMessage () + "]" )
11071106                );
1108-                 AbstractSearchAsyncAction <?  extends   SearchPhaseResult >  searchAsyncAction  =  switch   (searchRequest .searchType ()) {
1109-                     case   DFS_QUERY_THEN_FETCH  ->  new  SearchDfsQueryThenFetchAsyncAction (
1107+                 if   (searchRequest .searchType () ==  DFS_QUERY_THEN_FETCH ) {
1108+                     return  new  SearchDfsQueryThenFetchAsyncAction (
11101109                        logger ,
11111110                        searchTransportService ,
11121111                        connectionLookup ,
@@ -1122,7 +1121,9 @@ public SearchPhase newSearchPhase(
11221121                        task ,
11231122                        clusters 
11241123                    );
1125-                     case  QUERY_THEN_FETCH  -> new  SearchQueryThenFetchAsyncAction (
1124+                 } else  {
1125+                     assert  searchRequest .searchType () == QUERY_THEN_FETCH  : searchRequest .searchType ();
1126+                     return  new  SearchQueryThenFetchAsyncAction (
11261127                        logger ,
11271128                        searchTransportService ,
11281129                        connectionLookup ,
@@ -1138,8 +1139,7 @@ public SearchPhase newSearchPhase(
11381139                        task ,
11391140                        clusters 
11401141                    );
1141-                 };
1142-                 return  searchAsyncAction ;
1142+                 }
11431143            }
11441144        }
11451145    }
    
 
   
 
     
   
   
          
     
  
    
     
 
    
      
     
 
     
    You can’t perform that action at this time.
  
 
    
  
     
    
      
        
     
 
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments