[CI] EsqlSpecIT test {csv-spec:text-embedding.Text_embedding with multiple knn queries in fork} failing

[elasticsearchmachine]

Build Scans:

• elasticsearch-intake #29734 / part3
• elasticsearch-pull-request #97310 / part-3-fips
• elasticsearch-intake #29684 / part3

Reproduction Line:

./gradlew ":x-pack:plugin:esql:qa:server:multi-node:javaRestTest" --tests "org.elasticsearch.xpack.esql.qa.multi_node.EsqlSpecIT" -Dtests.method="test {csv-spec:text-embedding.Text_embedding with multiple knn queries in fork}" -Dtests.seed=6F4FCA619D4BB208 -Dtests.locale=lo -Dtests.timezone=Portugal -Druntime.java=25

Applicable branches:
main

Reproduces locally?:
N/A

Failure History:
See dashboard

Failure Message:

java.net.ConnectException: Connection refused

Issue Reasons:

• [main] 3 failures in test test {csv-spec:text-embedding.Text_embedding with multiple knn queries in fork} (2.0% fail rate in 147 executions)
• [main] 2 failures in step part3 (5.9% fail rate in 34 executions)
• [main] 2 failures in pipeline elasticsearch-intake (5.9% fail rate in 34 executions)

Note:
This issue was created using new test triage automation. Please report issues or feedback to es-delivery.

[elasticsearchmachine]

This has been muted on branch main

Mute Reasons:

• [main] 2 failures in test test {csv-spec:text-embedding.Text_embedding with multiple knn queries in fork} (6.3% fail rate in 32 executions)

Build Scans:

• elasticsearch-intake #29683 / part3
• elasticsearch-pull-request #97172 / part-3

[elasticsearchmachine]

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

[elasticsearchmachine]

This has been muted on branch main

Mute Reasons:

• [main] 3 failures in test test {csv-spec:text-embedding.Text_embedding with multiple knn queries in fork} (2.0% fail rate in 147 executions)
• [main] 2 failures in step part3 (5.9% fail rate in 34 executions)
• [main] 2 failures in pipeline elasticsearch-intake (5.9% fail rate in 34 executions)

Build Scans:

• elasticsearch-intake #29734 / part3
• elasticsearch-pull-request #97310 / part-3-fips
• elasticsearch-intake #29684 / part3

[astefan]

[2025-10-08T00:34:34,265][INFO ][o.e.x.e.q.m.EsqlSpecIT   ][test] [csv-spec:text-embedding.Text_embedding with multiple knn queries in fork] before test
[2025-10-08T00:34:34,338][ERROR][o.e.b.ElasticsearchUncaughtExceptionHandler] [test-cluster-0] fatal error in thread [elasticsearch[test-cluster-0][search][T#2]], exiting java.lang.AssertionError: returned more bytes than it used
	at org.elasticsearch.xpack.esql.core.expression.FoldContext$1.addWithoutBreaking(FoldContext.java:118)
	at org.elasticsearch.compute.data.BlockFactory.adjustBreaker(BlockFactory.java:90)
	at org.elasticsearch.compute.data.AbstractVector.closeInternal(AbstractVector.java:39)
	at org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted.decRef(AbstractNonThreadSafeRefCounted.java:46)
	at org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted.close(AbstractNonThreadSafeRefCounted.java:59)
	at org.elasticsearch.base@9.3.0-SNAPSHOT/org.elasticsearch.core.Releasables.close(Releasables.java:39)
	at org.elasticsearch.base@9.3.0-SNAPSHOT/org.elasticsearch.core.Releasables.closeExpectNoException(Releasables.java:72)
	at org.elasticsearch.compute.data.FloatArrayBlock.closeInternal(FloatArrayBlock.java:247)
	at org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted.decRef(AbstractNonThreadSafeRefCounted.java:46)
	at org.elasticsearch.compute.data.AbstractNonThreadSafeRefCounted.close(AbstractNonThreadSafeRefCounted.java:59)
	at org.elasticsearch.base@9.3.0-SNAPSHOT/org.elasticsearch.core.Releasables.close(Releasables.java:39)
	at org.elasticsearch.base@9.3.0-SNAPSHOT/org.elasticsearch.core.Releasables.close(Releasables.java:48)
	at org.elasticsearch.base@9.3.0-SNAPSHOT/org.elasticsearch.core.Releasables.closeExpectNoException(Releasables.java:62)
	at org.elasticsearch.compute.data.Page.releaseBlocks(Page.java:245)
	at org.elasticsearch.xpack.esql.inference.InferenceFunctionEvaluator.lambda$fold$0(InferenceFunctionEvaluator.java:136)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$ResponseDroppingActionListener.onResponse(ActionListenerImplementations.java:288)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.support.SubscribableListener$SuccessResult.complete(SubscribableListener.java:406)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.support.SubscribableListener.tryComplete(SubscribableListener.java:326)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.support.SubscribableListener.setResult(SubscribableListener.java:355)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.support.SubscribableListener.onResponse(SubscribableListener.java:262)
	at org.elasticsearch.compute.operator.DriverContext$AsyncActions.removeInstance(DriverContext.java:237)
	at org.elasticsearch.compute.operator.DriverContext.removeAsyncAction(DriverContext.java:169)
	at org.elasticsearch.compute.operator.AsyncOperator.lambda$addInput$2(AsyncOperator.java:107)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$RunAfterActionListener.onResponse(ActionListenerImplementations.java:314)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListener$3.onResponse(ActionListener.java:413)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$RunBeforeActionListener.onResponse(ActionListenerImplementations.java:350)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListener$3.onResponse(ActionListener.java:413)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$MappedActionListener.onResponse(ActionListenerImplementations.java:111)
	at org.elasticsearch.xpack.esql.inference.bulk.BulkInferenceRunner.lambda$executeBulk$0(BulkInferenceRunner.java:102)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$ResponseDroppingActionListener.onResponse(ActionListenerImplementations.java:288)
	at org.elasticsearch.xpack.esql.inference.bulk.BulkInferenceRunner$BulkInferenceRequest.onBulkCompletion(BulkInferenceRunner.java:355)
	at org.elasticsearch.xpack.esql.inference.bulk.BulkInferenceRunner$BulkInferenceRequest.lambda$executePendingRequests$2(BulkInferenceRunner.java:273)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListenerImplementations$RunAfterActionListener.onResponse(ActionListenerImplementations.java:314)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.ActionListener$3.onResponse(ActionListener.java:413)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.action.support.ThreadedActionListener$1.doRun(ThreadedActionListener.java:40)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.common.util.concurrent.TimedRunnable.doRun(TimedRunnable.java:35)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:1067)
	at org.elasticsearch.server@9.3.0-SNAPSHOT/org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:27)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
	at java.base/java.lang.Thread.run(Thread.java:1474)

This one seems to be in the same ballpark source of the issue as #136089