Fix

Tim-Brooks · May 11, 2024 · 3a9a597 · 3a9a597
1 parent 1768fe5
commit 3a9a597
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/test/framework/src/main/java/org/elasticsearch/test/InternalTestCluster.java b/test/framework/src/main/java/org/elasticsearch/test/InternalTestCluster.java
@@ -1302,16 +1302,26 @@ private void assertAllPendingWriteLimitsReleased() throws Exception {
             for (NodeAndClient nodeAndClient : nodes.values()) {
                 IndexingPressure indexingPressure = getInstance(IndexingPressure.class, nodeAndClient.name);
                 final long combinedBytes = indexingPressure.stats().getCurrentCombinedCoordinatingAndPrimaryBytes();
+                final long coordinatingBytes = indexingPressure.stats().getCurrentCoordinatingBytes();
+                final long primaryBytes = indexingPressure.stats().getCurrentPrimaryBytes();
                 if (combinedBytes > 0) {
-                    throw new AssertionError("pending combined bytes [" + combinedBytes + "] bytes on node [" + nodeAndClient.name + "].");
+                    throw new AssertionError(
+                        "pending combined bytes ["
+                            + combinedBytes
+                            + "] bytes, pending coordinating bytes ["
+                            + coordinatingBytes
+                            + "], pending primary bytes ["
+                            + primaryBytes
+                            + "] on node ["
+                            + nodeAndClient.name
+                            + "]."
+                    );
                 }
-                final long coordinatingBytes = indexingPressure.stats().getCurrentCoordinatingBytes();
                 if (coordinatingBytes > 0) {
                     throw new AssertionError(
                         "pending coordinating bytes [" + coordinatingBytes + "] bytes on node [" + nodeAndClient.name + "]."
                     );
                 }
-                final long primaryBytes = indexingPressure.stats().getCurrentPrimaryBytes();
                 if (primaryBytes > 0) {
                     throw new AssertionError("pending primary bytes [" + primaryBytes + "] bytes on node [" + nodeAndClient.name + "].");
                 }