@@ -121,7 +121,7 @@ public interface PlanRunner {
121121 private final IndicesExpressionGrouper indicesExpressionGrouper ;
122122 private final InferenceService inferenceService ;
123123 private final RemoteClusterService remoteClusterService ;
124- private final ExecutorService optimizerExecutor ;
124+ private final ExecutorService planExecutor ;
125125
126126 private boolean explainMode ;
127127 private String parsedPlanString ;
@@ -158,7 +158,7 @@ public EsqlSession(
158158 this .inferenceService = services .inferenceService ();
159159 this .preMapper = new PreMapper (services );
160160 this .remoteClusterService = services .transportService ().getRemoteClusterService ();
161- this .optimizerExecutor = services .transportService ().getThreadPool ().executor (ThreadPool .Names .SEARCH );
161+ this .planExecutor = services .transportService ().getThreadPool ().executor (ThreadPool .Names .SEARCH );
162162 }
163163
164164 public String sessionId () {
@@ -183,7 +183,7 @@ public void execute(EsqlQueryRequest request, EsqlExecutionInfo executionInfo, P
183183 public void onResponse (LogicalPlan analyzedPlan ) {
184184 SubscribableListener .<LogicalPlan >newForked (l -> preOptimizedPlan (analyzedPlan , l ))
185185 .andThenApply (p -> optimizedPlan (p ))
186- .<LogicalPlan >andThen ((l , p ) -> preMapper .preMapper (p , new ThreadedActionListener <>(optimizerExecutor , l )))
186+ .<LogicalPlan >andThen ((l , p ) -> preMapper .preMapper (p , new ThreadedActionListener <>(planExecutor , l )))
187187 .<Result >andThen ((l , p ) -> executeOptimizedPlan (request , executionInfo , planRunner , p , l ))
188188 .addListener (listener );
189189 }
0 commit comments