Skip to content

Commit 35485d9

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent 7de5c3d commit 35485d9

File tree

1 file changed

+6
-7
lines changed
  • x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session

1 file changed

+6
-7
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlSession.java

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -183,13 +183,12 @@ public void onResponse(LogicalPlan analyzedPlan) {
183183
ThreadPool.Names.SEARCH_COORDINATION,
184184
ThreadPool.Names.SYSTEM_READ
185185
);
186-
SubscribableListener.<LogicalPlan>newForked(l -> preOptimizedPlan(analyzedPlan, l))
187-
.<LogicalPlan>andThen((l, p) -> {
188-
if (request.approximate()) {
189-
new Approximate(p); // to verify whether the pre-optimized plan is suitable for approximation
190-
}
191-
l.onResponse(p);
192-
})
186+
SubscribableListener.<LogicalPlan>newForked(l -> preOptimizedPlan(analyzedPlan, l)).<LogicalPlan>andThen((l, p) -> {
187+
if (request.approximate()) {
188+
new Approximate(p); // to verify whether the pre-optimized plan is suitable for approximation
189+
}
190+
l.onResponse(p);
191+
})
193192
.<LogicalPlan>andThen((l, p) -> preMapper.preMapper(optimizedPlan(p), l))
194193
.<Result>andThen((l, p) -> executeOptimizedPlan(request, executionInfo, planRunner, p, l))
195194
.addListener(listener);

0 commit comments

Comments
 (0)