Skip to content

Commit a25940c

Browse files
committed
Don't push sample correction through mv_expand
1 parent 2133560 commit a25940c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/optimizer/rules/logical/ApplySampleCorrections.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import org.elasticsearch.xpack.esql.plan.logical.Aggregate;
1414
import org.elasticsearch.xpack.esql.plan.logical.Limit;
1515
import org.elasticsearch.xpack.esql.plan.logical.LogicalPlan;
16+
import org.elasticsearch.xpack.esql.plan.logical.MvExpand;
1617
import org.elasticsearch.xpack.esql.plan.logical.Sample;
1718
import org.elasticsearch.xpack.esql.rule.Rule;
1819

@@ -25,7 +26,7 @@ public LogicalPlan apply(LogicalPlan logicalPlan) {
2526
if (plan instanceof Sample sample) {
2627
sampleProbability.set(sample.probability());
2728
}
28-
if (plan instanceof Limit) {
29+
if (plan instanceof Limit || plan instanceof MvExpand) {
2930
sampleProbability.set(null);
3031
}
3132
if (plan instanceof Aggregate && sampleProbability.get() != null) {

0 commit comments

Comments
 (0)