From 06fff8f794abe096e38c75548d152e4dacfd3dda Mon Sep 17 00:00:00 2001 From: Lorenzo Dematte Date: Sat, 12 Jul 2025 17:38:59 +0200 Subject: [PATCH] Add exception logging when interrupted --- .../common/util/concurrent/AbstractAsyncTaskTests.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/server/src/test/java/org/elasticsearch/common/util/concurrent/AbstractAsyncTaskTests.java b/server/src/test/java/org/elasticsearch/common/util/concurrent/AbstractAsyncTaskTests.java index ec8e0f69d89d8..a193bcd8a89ed 100644 --- a/server/src/test/java/org/elasticsearch/common/util/concurrent/AbstractAsyncTaskTests.java +++ b/server/src/test/java/org/elasticsearch/common/util/concurrent/AbstractAsyncTaskTests.java @@ -59,12 +59,14 @@ protected void runInternal() { try { barrier1.await(); } catch (Exception e) { + logger.error("barrier1 interrupted", e); fail("interrupted"); } count.incrementAndGet(); try { barrier2.await(); } catch (Exception e) { + logger.error("barrier2 interrupted", e); fail("interrupted"); } if (shouldRunThrowException) { @@ -112,6 +114,7 @@ protected void runInternal() { try { barrier.await(); } catch (Exception e) { + logger.error("barrier interrupted", e); fail("interrupted"); } if (shouldRunThrowException) {