Skip to content

Commit cd57460

Browse files
committed
Small fixes
1 parent db33e26 commit cd57460

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterEnrichUnavailableClustersIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@
3030
import static org.hamcrest.Matchers.lessThanOrEqualTo;
3131

3232
/**
33-
* This IT test is the dual of CrossClustersEnrichIT, which tests "happy path"
33+
* This IT test is the dual of CrossClusterEnrichIT, which tests "happy path"
3434
* and this one tests unavailable cluster scenarios using (most of) the same tests.
3535
*/
3636
public class CrossClusterEnrichUnavailableClustersIT extends AbstractEnrichBasedCrossClusterTestCase {
@@ -53,6 +53,7 @@ protected Collection<Class<? extends Plugin>> nodePlugins(String clusterAlias) {
5353
return plugins;
5454
}
5555

56+
5657
public void testEnrichWithHostsPolicyAndDisconnectedRemotesWithSkipUnavailableTrue() throws IOException {
5758
setSkipUnavailable(REMOTE_CLUSTER_1, true);
5859
setSkipUnavailable(REMOTE_CLUSTER_2, true);

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/parser/LogicalPlanBuilder.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -484,9 +484,9 @@ public PlanFactory visitEnrichCommand(EsqlBaseParser.EnrichCommandContext ctx) {
484484
List<NamedExpression> keepClauses = visitList(this, ctx.enrichWithClause(), NamedExpression.class);
485485

486486
// If this is a remote-only ENRICH, any upstream LOOKUP JOINs need to be treated as remote-only, too.
487-
LogicalPlan updatedChild = (mode == Mode.REMOTE) == false
488-
? child
489-
: child.transformDown(LookupJoin.class, lj -> new LookupJoin(lj.source(), lj.left(), lj.right(), lj.config(), true));
487+
LogicalPlan updatedChild = (mode == Mode.REMOTE)
488+
? child.transformDown(LookupJoin.class, lj -> new LookupJoin(lj.source(), lj.left(), lj.right(), lj.config(), true))
489+
: child;
490490

491491
return new Enrich(
492492
source,

0 commit comments

Comments
 (0)