Skip to content

Commit 608a226

Browse files
committed
reorder resolveAsMergedMapping parameters
1 parent dacf282 commit 608a226

File tree

3 files changed

+8
-8
lines changed

3 files changed

+8
-8
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/enrich/EnrichPolicyResolver.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -446,7 +446,7 @@ public void messageReceived(LookupRequest request, TransportChannel channel, Tas
446446
}
447447
try (ThreadContext.StoredContext ignored = threadContext.stashWithOrigin(ClientHelper.ENRICH_ORIGIN)) {
448448
String indexName = EnrichPolicy.getBaseName(policyName);
449-
indexResolver.resolveAsMergedMapping(indexName, IndexResolver.ALL_FIELDS, null, refs.acquire(indexResult -> {
449+
indexResolver.resolveAsMergedMapping(indexName, IndexResolver.ALL_FIELDS, null, false, refs.acquire(indexResult -> {
450450
if (indexResult.isValid() && indexResult.get().concreteIndices().size() == 1) {
451451
EsIndex esIndex = indexResult.get();
452452
var concreteIndices = Map.of(request.clusterAlias, Iterables.get(esIndex.concreteIndices(), 0));
@@ -461,7 +461,7 @@ public void messageReceived(LookupRequest request, TransportChannel channel, Tas
461461
} else {
462462
failures.put(policyName, indexResult.toString());
463463
}
464-
}), false);
464+
}));
465465
}
466466
}
467467
}

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -422,8 +422,8 @@ private void preAnalyzeLookupIndex(
422422
patternWithRemotes,
423423
fieldNames,
424424
null,
425-
listener.map(indexResolution -> receiveLookupIndexResolution(result, localPattern, executionInfo, indexResolution)),
426-
false
425+
false,
426+
listener.map(indexResolution -> receiveLookupIndexResolution(result, localPattern, executionInfo, indexResolution))
427427
);
428428
}
429429

@@ -653,10 +653,10 @@ private void preAnalyzeMainIndices(
653653
indexExpressionToResolve,
654654
result.fieldNames,
655655
requestFilter,
656+
includeAllDimensions,
656657
listener.delegateFailure((l, indexResolution) -> {
657658
l.onResponse(result.withIndexResolution(indexResolution));
658-
}),
659-
includeAllDimensions
659+
})
660660
);
661661
}
662662
} else {

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -81,8 +81,8 @@ public void resolveAsMergedMapping(
8181
String indexWildcard,
8282
Set<String> fieldNames,
8383
QueryBuilder requestFilter,
84-
ActionListener<IndexResolution> listener,
85-
boolean includeAllDimensions
84+
boolean includeAllDimensions,
85+
ActionListener<IndexResolution> listener
8686
) {
8787
client.execute(
8888
EsqlResolveFieldsAction.TYPE,

0 commit comments

Comments
 (0)