[ES|QL] ClassCastException in PercentileDoubleGroupingAggregatorFunction

[lkts]

Elasticsearch Version

main

Installed Plugins

No response

Java Version

bundled

OS Version

n/a

Problem Description

The following error was observed:

java.lang.ClassCastException: class org.elasticsearch.compute.data.LongVectorBlock cannot be cast to class org.elasticsearch.compute.data.BytesRefBlock (org.elasticsearch.compute.data.LongVectorBlock and org.elasticsearch.compute.data.BytesRefBlock are in unnamed module of loader java.net.URLClassLoader @1174676f)
	at org.elasticsearch.compute.aggregation.PercentileDoubleGroupingAggregatorFunction.addIntermediateInput(PercentileDoubleGroupingAggregatorFunction.java:173)
	at org.elasticsearch.compute.aggregation.GroupingAggregator$1.add(GroupingAggregator.java:50)
	at org.elasticsearch.compute.operator.HashAggregationOperator$1AddInput.add(HashAggregationOperator.java:165)
	at org.elasticsearch.compute.aggregation.blockhash.BytesRef3BlockHash.addVectors(BytesRef3BlockHash.java:95)
	at org.elasticsearch.compute.aggregation.blockhash.BytesRef3BlockHash.add(BytesRef3BlockHash.java:75)
	at org.elasticsearch.compute.operator.HashAggregationOperator.addInput(HashAggregationOperator.java:193)
	at org.elasticsearch.compute.operator.Driver.runSingleLoopIteration(Driver.java:276)
	at org.elasticsearch.compute.operator.Driver.run(Driver.java:184)
	at org.elasticsearch.compute.operator.Driver$1.doRun(Driver.java:403)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at org.elasticsearch.compute.operator.DriverScheduler$1.doRun(DriverScheduler.java:57)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.TimedRunnable.doRun(TimedRunnable.java:34)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:1044)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1095)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:619)
	at java.base/java.lang.Thread.run(Thread.java:1447)

There are mentions of similar error in #100047 so i suspect a malformed query.

Steps to Reproduce

N/A

Logs (if relevant)

No response

[elasticsearchmachine]

Pinging @elastic/es-analytical-engine (Team:Analytics)

[dnhatn]

@lkts Do you have the query?

[lkts]

unfortunately no, this is a customer query

[wchaparro]

closing as can't repro

[jilldoty-elastic]

Similar stack trace found, no query available.

java.lang.ClassCastException: class org.elasticsearch.compute.data.LongVectorBlock cannot be cast to class org.elasticsearch.compute.data.BytesRefBlock (org.elasticsearch.compute.data.LongVectorBlock and org.elasticsearch.compute.data.BytesRefBlock are in unnamed module of loader java.net.URLClassLoader @27210a3b)
	at org.elasticsearch.compute.aggregation.blockhash.BytesRef2BlockHash.add(BytesRef2BlockHash.java:65)
	at org.elasticsearch.compute.operator.HashAggregationOperator.addInput(HashAggregationOperator.java:203)
	at org.elasticsearch.compute.operator.Driver.runSingleLoopIteration(Driver.java:279)
	at org.elasticsearch.compute.operator.Driver.run(Driver.java:185)
	at org.elasticsearch.compute.operator.Driver$1.doRun(Driver.java:406)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at org.elasticsearch.compute.operator.DriverScheduler$1.doRun(DriverScheduler.java:57)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.TimedRunnable.doRun(TimedRunnable.java:35)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:1044)
	at org.elasticsearch.server@9.1.0/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1095)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:619)
	at java.base/java.lang.Thread.run(Thread.java:1447)

[alex-spies]

Re-opened as this continues happening.

@nik9000 , should we go for more visibility in error cases? Like, could we log the operators in the driver if we catch an exception during execution, so we can at least more or less know what query we ran?

[dnhatn]

I can reproduce this and will work on a fix.