Don't be backwards

nik9000 · nik9000 · commit 4bdc7e390e1b · 2025-07-10T09:27:51.000-04:00
diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/PlannerUtils.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/PlannerUtils.java
@@ -202,7 +202,7 @@ static QueryBuilder detectFilter(TransportVersion minTransportVersion, PhysicalP
         final List<QueryBuilder> requestFilters = new ArrayList<>();
         final LucenePushdownPredicates ctx = LucenePushdownPredicates.forCanMatch(minTransportVersion);
         plan.forEachDown(FragmentExec.class, fe -> {
-            if (fe.esFilter() != null && fe.esFilter().getMinimalSupportedVersion().onOrAfter(minTransportVersion)) {
+            if (fe.esFilter() != null && minTransportVersion.onOrAfter(fe.esFilter().getMinimalSupportedVersion())) {
                 requestFilters.add(fe.esFilter());
             }
             // detect filter inside the query

Original file line number	Diff line number	Diff line change
`@@ -202,7 +202,7 @@ static QueryBuilder detectFilter(TransportVersion minTransportVersion, PhysicalP`
`202`	`202`	`final List<QueryBuilder> requestFilters = new ArrayList<>();`
`203`	`203`	`final LucenePushdownPredicates ctx = LucenePushdownPredicates.forCanMatch(minTransportVersion);`
`204`	`204`	`plan.forEachDown(FragmentExec.class, fe -> {`
`205`		`- if (fe.esFilter() != null && fe.esFilter().getMinimalSupportedVersion().onOrAfter(minTransportVersion)) {`
	`205`	`+ if (fe.esFilter() != null && minTransportVersion.onOrAfter(fe.esFilter().getMinimalSupportedVersion())) {`
`206`	`206`	`requestFilters.add(fe.esFilter());`
`207`	`207`	`}`
`208`	`208`	`// detect filter inside the query`