diff --git a/x-pack/plugin/src/test/java/org/elasticsearch/xpack/test/rest/AbstractXPackRestTest.java b/x-pack/plugin/src/test/java/org/elasticsearch/xpack/test/rest/AbstractXPackRestTest.java index e8c3250bf2e46..7163a5ef82897 100644 --- a/x-pack/plugin/src/test/java/org/elasticsearch/xpack/test/rest/AbstractXPackRestTest.java +++ b/x-pack/plugin/src/test/java/org/elasticsearch/xpack/test/rest/AbstractXPackRestTest.java @@ -125,8 +125,8 @@ public void cleanup() throws Exception { protected Predicate waitForPendingTasksFilter() { return task -> { - // Don't check rollup jobs because we clear them in the superclass. - return task.contains(RollupJob.NAME); + // Don't check rollup jobs or data stream reindex tasks because we clear them in the superclass. + return task.contains(RollupJob.NAME) || task.contains("reindex-data-stream"); }; }