diff --git a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/persistence/JobStorageDeletionTask.java b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/persistence/JobStorageDeletionTask.java index 0e7135d0bac..1796c624696 100644 --- a/plugin/src/main/java/org/elasticsearch/xpack/ml/job/persistence/JobStorageDeletionTask.java +++ b/plugin/src/main/java/org/elasticsearch/xpack/ml/job/persistence/JobStorageDeletionTask.java @@ -103,7 +103,6 @@ public class JobStorageDeletionTask extends Task { // Step 2. DBQ done, delete the state // ------- - // TODO norelease more robust handling of failures? ActionListener dbqHandler = ActionListener.wrap(bulkByScrollResponse -> { if (bulkByScrollResponse.isTimedOut()) { logger.warn("DeleteByQuery for indices [" + indexName + ", " + indexPattern + "] timed out.");