[Transform] Add an assertion to the testTransformFeatureReset test case

elastic · Oct 4, 2023 · 8b54455 · 8b54455
1 parent 22a0ae1
commit 8b54455
Showing 1 changed file with 14 additions and 1 deletion.
diff --git a/...c/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TestFeatureResetIT.java b/...c/javaRestTest/java/org/elasticsearch/xpack/transform/integration/TestFeatureResetIT.java
@@ -11,6 +11,7 @@
 import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.Response;
 import org.elasticsearch.common.Strings;
+import org.elasticsearch.common.xcontent.support.XContentMapValues;
 import org.elasticsearch.core.TimeValue;
 import org.elasticsearch.search.aggregations.AggregationBuilders;
 import org.elasticsearch.search.aggregations.AggregatorFactories;
@@ -43,7 +44,9 @@ public void setLogging() throws IOException {
             {
               "persistent": {
                 "logger.org.elasticsearch.xpack.core.indexing.AsyncTwoPhaseIndexer": "debug",
-                "logger.org.elasticsearch.xpack.transform": "trace"
+                "logger.org.elasticsearch.xpack.transform": "trace",
+                "logger.org.elasticsearch.xpack.transform.notifications": "debug",
+                "logger.org.elasticsearch.xpack.transform.transforms": "debug"
               }
             }""");
         client().performRequest(settingsRequest);
@@ -100,6 +103,16 @@ public void testTransformFeatureReset() throws Exception {
         // assert transforms are gone
         assertThat((Integer) getTransforms("_all").get("count"), equalTo(0));
 
+        // assert transform documents are gone
+        Map<String, Object> transformIndicesContents = ESRestTestCase.entityAsMap(
+            adminClient().performRequest(new Request("GET", ".transform-*/_search"))
+        );
+        assertThat(
+            "Indices contents were: " + transformIndicesContents,
+            XContentMapValues.extractValue(transformIndicesContents, "hits", "total", "value"),
+            is(equalTo(0))
+        );
+
         // assert transform indices are gone
         assertThat(ESRestTestCase.entityAsMap(adminClient().performRequest(new Request("GET", ".transform-*"))), is(anEmptyMap()));
     }