Skip to content

Commit 482dfec

Browse files
author
elasticsearchmachine
committed
Check that expression is numeric before pushing down
1 parent c95106b commit 482dfec

File tree

1 file changed

+4
-3
lines changed
  • x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/optimizer/rules/physical/local

1 file changed

+4
-3
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/optimizer/rules/physical/local/PushTopNToSource.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -179,9 +179,10 @@ && canPushLimit(topNExec, plannerSettings)) {
179179
distances.put(alias.id(), distance);
180180
} else if (alias.child() instanceof Attribute attr) {
181181
aliasReplacedByBuilder.put(alias.toAttribute(), attr.toAttribute());
182-
} else if (alias.child().pushableOptions() == Expression.PushableOptions.PREFERRED) {
183-
pushableExpressions.put(alias.id(), alias);
184-
}
182+
} else if (alias.child().dataType().isNumeric()
183+
&& (alias.child().pushableOptions() == Expression.PushableOptions.PREFERRED)) {
184+
pushableExpressions.put(alias.id(), alias);
185+
}
185186
});
186187
AttributeMap<Attribute> aliasReplacedBy = aliasReplacedByBuilder.build();
187188

0 commit comments

Comments
 (0)