[CI] EnrichIT testListeningRatio failing

[benwtrent]

Build scan:
https://gradle-enterprise.elastic.co/s/gg6slpy3q6pfo/tests/:x-pack:plugin:esql:internalClusterTest/org.elasticsearch.xpack.esql.action.EnrichIT/testListeningRatio

Reproduction line:

./gradlew ':x-pack:plugin:esql:internalClusterTest' --tests "org.elasticsearch.xpack.esql.action.EnrichIT.testListeningRatio" -Dtests.seed=DF4CDC0FFA0D2B5A -Dtests.locale=nn-NO -Dtests.timezone=BET -Druntime.java=22

Applicable branches:
main

Reproduces locally?:
Didn't try

Failure history:
Failure dashboard for org.elasticsearch.xpack.esql.action.EnrichIT#testListeningRatio

Failure excerpt:

org.elasticsearch.ResourceNotFoundException: sink exchanger for id [X-0HDkoMR1WQ6Vf59zXpFQ:23] doesn't exist

  at __randomizedtesting.SeedInfo.seed([DF4CDC0FFA0D2B5A:2CED2CE9A0414374]:0)
  at org.elasticsearch.compute.operator.exchange.ExchangeService.getSinkHandler(ExchangeService.java:131)
  at org.elasticsearch.xpack.esql.plugin.ComputeService.runComputeOnDataNode(ComputeService.java:714)
  at org.elasticsearch.xpack.esql.plugin.ComputeService$DataNodeRequestHandler.messageReceived(ComputeService.java:787)
  at org.elasticsearch.xpack.esql.plugin.ComputeService$DataNodeRequestHandler.messageReceived(ComputeService.java:754)
  at org.elasticsearch.transport.RequestHandlerRegistry.processMessageReceived(RequestHandlerRegistry.java:75)
  at org.elasticsearch.transport.InboundHandler.doHandleRequest(InboundHandler.java:287)
  at org.elasticsearch.transport.InboundHandler$1.doRun(InboundHandler.java:300)
  at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:984)
  at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:26)
  at org.elasticsearch.common.util.concurrent.TimedRunnable.doRun(TimedRunnable.java:33)
  at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:984)
  at org.elasticsearch.common.util.concurrent.AbstractRunnable.run(AbstractRunnable.java:26)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
  at java.lang.Thread.run(Thread.java:1570)

[elasticsearchmachine]

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

[benwtrent]

It doesn't reproduce reliably, but looking at the test history, it definitely seems flaky. If this continues to fail, we should mute.

[nik9000]

@dnhatn, another one of these sink exchanger for id [XXXX] doesn't exist tests.

[dnhatn]

@nik9000 Yes, there are some issues with the exchange timeout. I will spend some time on it.

[alex-spies]

Got another one like that for testTopN: https://gradle-enterprise.elastic.co/s/cgidqjkhcriq2/tests/task/:x-pack:plugin:esql:internalClusterTest/details/org.elasticsearch.xpack.esql.action.EnrichIT/testTopN

[dnhatn]

Fixed in #110450