REPRODUCE WITH: ./gradlew 'null' --tests "org.elasticsearch.xpack.esql.action.ManyShardsIT.testConcurrentQueries" -Dtests.seed=9AD8895DAA31433E -Dtests.locale=pl -Dtests.timezone=Asia/Dubai -Druntime.java=19

java.lang.AssertionError: Request breaker not reset to 0 on node: node_s0
Expected: <0L>
     but: was <192L>
Expected :<0L>
Actual   :<192L>
<Click to see difference>


	at __randomizedtesting.SeedInfo.seed([9AD8895DAA31433E:D8436A782A56361F]:0)
	at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:18)
	at org.junit.Assert.assertThat(Assert.java:956)
	at org.elasticsearch.test.InternalTestCluster.lambda$ensureEstimatedStats$41(InternalTestCluster.java:2439)
	at org.elasticsearch.test.ESTestCase.assertBusy(ESTestCase.java:1196)
	at org.elasticsearch.test.ESTestCase.assertBusy(ESTestCase.java:1169)
	at org.elasticsearch.test.InternalTestCluster.ensureEstimatedStats(InternalTestCluster.java:2437)
	at org.elasticsearch.test.TestCluster.assertAfterTest(TestCluster.java:92)
	at org.elasticsearch.test.InternalTestCluster.assertAfterTest(InternalTestCluster.java:2486)
	at org.elasticsearch.test.ESIntegTestCase.afterInternal(ESIntegTestCase.java:590)
	at org.elasticsearch.test.ESIntegTestCase.cleanUpCluster(ESIntegTestCase.java:2327)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104)
	at java.base/java.lang.reflect.Method.invoke(Method.java:578)
	at com.carrotsearch.randomizedtesting.RandomizedRunner.invoke(RandomizedRunner.java:1758)
	at com.carrotsearch.randomizedtesting.RandomizedRunner$10.evaluate(RandomizedRunner.java:1004)
	at com.carrotsearch.randomizedtesting.rules.StatementAdapter.evaluate(StatementAdapter.java:36)
	at org.apache.lucene.tests.util.TestRuleSetupTeardownChained$1.evaluate(TestRuleSetupTeardownChained.java:48)
	at org.apache.lucene.tests.util.AbstractBeforeAfterRule$1.evaluate(AbstractBeforeAfterRule.java:43)

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/EsqlActionIT.java
try (EsqlQueryResponse results = run("from test | stats avg(count) by data | sort data")) {
            logger.info(results);
            assertThat(results.columns(), hasSize(2));
            assertEquals("avg(count)", results.columns().get(0).name());
            assertEquals("double", results.columns().get(0).type());
            assertEquals("data", results.columns().get(1).name());
            assertEquals("long", results.columns().get(1).type());
            record Group(Long data, Double avg) {}
            List<Group> expectedGroups = List.of(new Group(1L, 42.0), new Group(2L, 44.0), new Group(99L, null), new Group(null, 12.0));
            List<Group> actualGroups = getValuesList(results).stream().map(l -> new Group((Long) l.get(1), (Double) l.get(0))).toList();
            assertThat(actualGroups, equalTo(expectedGroups));
        }
    }
    public void testFromStatsGroupingByKeyword() {
        EsqlQueryResponse results = run("from test | stats avg(count) by color");
        logger.info(results);
        Assert.assertEquals(2, results.columns().size());
        Assert.assertEquals(3, getValuesList(results).size());
        
        assertEquals("avg(count)", results.columns().get(0).name());
        assertEquals("double", results.columns().get(0).type());
        assertEquals("color", results.columns().get(1).name());
        assertEquals("keyword", results.columns().get(1).type());
        record Group(String color, double avg) {
        }
        List<Group> expectedGroups = List.of(new Group("blue", 42.0), new Group("green", 44.0), new Group("red", 43));
        List<Group> actualGroups = getValuesList(results).stream()
            .map(l -> new Group((String) l.get(1), (Double) l.get(0)))
            .sorted(comparing(c -> c.color))
            .toList();