From 198c53b1ef5bc0ad2757b14849ff38e985f3a4ac Mon Sep 17 00:00:00 2001
From: Hendrik Muhs <hendrik.muhs@elastic.co>
Date: Fri, 14 Feb 2020 12:19:04 +0100
Subject: [PATCH] delete the transform to delete any docs which might have been
 written by the task after deleting the index

fixes #51347
---
 .../xpack/transform/integration/TransformRobustnessIT.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/x-pack/plugin/transform/qa/single-node-tests/src/test/java/org/elasticsearch/xpack/transform/integration/TransformRobustnessIT.java b/x-pack/plugin/transform/qa/single-node-tests/src/test/java/org/elasticsearch/xpack/transform/integration/TransformRobustnessIT.java
index 459f2e9e56844..9d069eb5f9366 100644
--- a/x-pack/plugin/transform/qa/single-node-tests/src/test/java/org/elasticsearch/xpack/transform/integration/TransformRobustnessIT.java
+++ b/x-pack/plugin/transform/qa/single-node-tests/src/test/java/org/elasticsearch/xpack/transform/integration/TransformRobustnessIT.java
@@ -90,6 +90,9 @@ public void testTaskRemovalAfterInternalIndexGotDeleted() throws Exception {
 
         // the task is gone
         assertEquals(0, getNumberOfTransformTasks());
+
+        // delete the transform because the task might have written a state doc, cleanup fails if the index isn't empty
+        deleteTransform(transformId);
     }
 
     @SuppressWarnings("unchecked")