diff --git a/test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java b/test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java index e46ed7d1f1235..56b9850caea39 100644 --- a/test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java +++ b/test/framework/src/main/java/org/elasticsearch/test/transport/MockTransportService.java @@ -443,6 +443,9 @@ public void sendRequest( TransportRequestOptions options ) { if (semaphore.tryAcquire()) { + if (action.startsWith("indices:data/write/bulk")) { + logger.error("Failed Bulk {}, {}", request, request.getParentTask()); + } toClose.add(connection); semaphore.release(); } else {