From ebd74f09cf6352cf9970196cc3b892f602a74b3e Mon Sep 17 00:00:00 2001 From: Nik Everett Date: Fri, 31 Mar 2017 10:56:39 -0400 Subject: [PATCH] Add extra debugging to reindex cancel tests Adds more diagnostics when reindex's cancel tests fail. It fails every once in a while and didn't have useful failure messages: https://elasticsearch-ci.elastic.co/job/elastic+elasticsearch+5.3+multijob-unix-compatibility/os=amazon/86/consoleFull --- .../org/elasticsearch/index/reindex/CancelTests.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java b/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java index 59c18320959..2785d535078 100644 --- a/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java +++ b/modules/reindex/src/test/java/org/elasticsearch/index/reindex/CancelTests.java @@ -161,7 +161,14 @@ public class CancelTests extends ReindexTestCase { }); // And check the status of the response - BulkByScrollResponse response = future.get(); + BulkByScrollResponse response; + try { + response = future.get(30, TimeUnit.SECONDS); + } catch (Exception e) { + String tasks = client().admin().cluster().prepareListTasks().setParentTaskId(mainTask.getTaskId()) + .setDetailed(true).get().toString(); + throw new RuntimeException("Exception while waiting for the response. Running tasks: " + tasks, e); + } assertThat(response.getReasonCancelled(), equalTo("by user request")); assertThat(response.getBulkFailures(), emptyIterable()); assertThat(response.getSearchFailures(), emptyIterable());