[CI] GenerativeForkIT test {csv-spec:text-embedding.Text_embedding using a row source operator} failing

[elasticsearchmachine]

Build Scans:

• elasticsearch-periodic-platform-support #11071 / ubuntu-2404-aarch64_checkpart3_platform-support-arm
• elasticsearch-pull-request #97150 / part-3
• elasticsearch-pull-request #97150 / part-3

Reproduction Line:

./gradlew ":x-pack:plugin:esql:qa:server:single-node:javaRestTest" --tests "org.elasticsearch.xpack.esql.qa.single_node.GenerativeForkIT" -Dtests.method="test {csv-spec:text-embedding.Text_embedding using a row source operator}" -Dtests.seed=17A3F0BF27C41242 -Dtests.locale=ta -Dtests.timezone=America/Aruba -Druntime.java=25

Applicable branches:
main

Reproduces locally?:
N/A

Failure History:
See dashboard

Failure Message:

org.apache.http.ConnectionClosedException: Connection is closed

Issue Reasons:

• [main] 3 failures in test test {csv-spec:text-embedding.Text_embedding using a row source operator} (0.8% fail rate in 382 executions)
• [main] 2 failures in step part-3 (0.9% fail rate in 213 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] 3 failures in test test {csv-spec:text-embedding.Text_embedding using a row source operator} (0.8% fail rate in 382 executions)
• [main] 2 failures in step part-3 (0.9% fail rate in 213 executions)

Build Scans:

• elasticsearch-periodic-platform-support #11071 / ubuntu-2404-aarch64_checkpart3_platform-support-arm
• elasticsearch-pull-request #97150 / part-3
• elasticsearch-pull-request #97150 / part-3

[elasticsearchmachine]

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

[astefan]

@afoucret I think this one needs the same muting you added in #136203.

It's the same error in logs:

[2025-10-08T17:33:23,285][INFO ][o.e.x.e.q.s.GenerativeForkIT][test] [csv-spec:text-embedding.Text_embedding using a row source operator] before test
[2025-10-08T17:33:23,305][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.FloatArrayBlock.closeInternal(FloatArrayBlock.java:246)
	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)

[elasticsearchmachine]

Pinging @elastic/es-search-relevance (Team:Search Relevance)