More logging

Tim-Brooks · May 13, 2024 · 8568a4e · 8568a4e
1 parent 3a9a597
commit 8568a4e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...rc/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java b/...rc/main/java/org/elasticsearch/action/support/replication/TransportReplicationAction.java
@@ -1015,6 +1015,7 @@ public void onNewClusterState(ClusterState state) {
 
                 @Override
                 public void onClusterServiceClose() {
+                    logger.error("Failed transport replication action because close {}", TransportReplicationAction.super.getClass());
                     finishAsFailed(new NodeClosedException(clusterService.localNode()));
                 }
 

diff --git a/test/framework/src/main/java/org/elasticsearch/test/InternalTestCluster.java b/test/framework/src/main/java/org/elasticsearch/test/InternalTestCluster.java
@@ -1305,6 +1305,7 @@ private void assertAllPendingWriteLimitsReleased() throws Exception {
                 final long coordinatingBytes = indexingPressure.stats().getCurrentCoordinatingBytes();
                 final long primaryBytes = indexingPressure.stats().getCurrentPrimaryBytes();
                 if (combinedBytes > 0) {
+                    logger.error("Outstanding tasks: \n{}", client().admin().cluster().prepareListTasks(nodeAndClient.name).get());
                     throw new AssertionError(
                         "pending combined bytes ["
                             + combinedBytes