diff --git a/muted-tests.yml b/muted-tests.yml index 7d170a5e8db2d..f7ac0ad55e2e7 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -211,9 +211,6 @@ tests: - class: org.elasticsearch.repositories.blobstore.testkit.integrity.RepositoryVerifyIntegrityIT method: testCorruption issue: https://github.com/elastic/elasticsearch/issues/112769 -- class: org.elasticsearch.repositories.blobstore.testkit.integrity.RepositoryVerifyIntegrityIT - method: testTransportException - issue: https://github.com/elastic/elasticsearch/issues/112779 - class: org.elasticsearch.script.StatsSummaryTests method: testEqualsAndHashCode issue: https://github.com/elastic/elasticsearch/issues/112439 diff --git a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/integrity/RepositoryIntegrityVerifier.java b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/integrity/RepositoryIntegrityVerifier.java index a5c81d18071fc..e10fe2b756f78 100644 --- a/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/integrity/RepositoryIntegrityVerifier.java +++ b/x-pack/plugin/snapshot-repo-test-kit/src/main/java/org/elasticsearch/repositories/blobstore/testkit/integrity/RepositoryIntegrityVerifier.java @@ -934,7 +934,11 @@ public void onResponse(Releasable releasable) { if (cancellableThreads.isCancelled()) { runnable.onFailure(new TaskCancelledException("task cancelled")); } else { - cancellableThreads.execute(runnable::run); + try { + cancellableThreads.execute(runnable::run); + } catch (RuntimeException e) { + runnable.onFailure(e); + } } } }