Extract dynamic filter explain analyze test method

trinodb · Mar 2, 2022 · e29fce5 · e29fce5
1 parent 21e6a06
commit e29fce5
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/...ng/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java b/...ng/trino-testing/src/main/java/io/trino/testing/AbstractDistributedEngineOnlyQueries.java
@@ -167,11 +167,6 @@ public void testExplainAnalyze()
                 "Right \\(build\\) Input avg\\.: .* rows, Input std\\.dev\\.: .*",
                 "Collisions avg\\.: .* \\(.* est\\.\\), Collisions std\\.dev\\.: .*");
 
-        // ExplainAnalyzeOperator may finish before dynamic filter stats are reported to QueryInfo
-        assertEventually(() -> assertExplainAnalyze(
-                "EXPLAIN ANALYZE SELECT * FROM nation a, nation b WHERE a.nationkey = b.nationkey",
-                "Dynamic filters: \n.*ranges=25, \\{\\[0], ..., \\[24]}.* collection time=\\d+.*"));
-
         assertExplainAnalyze(
                 "EXPLAIN ANALYZE SELECT nationkey FROM nation GROUP BY nationkey",
                 "Collisions avg\\.: .* \\(.* est\\.\\), Collisions std\\.dev\\.: .*");
@@ -181,6 +176,15 @@ public void testExplainAnalyze()
                 "Estimates: \\{rows: .* \\(.*\\), cpu: .*, memory: .*, network: .*}");
     }
 
+    @Test
+    public void testExplainAnalyzeDynamicFilterInfo()
+    {
+        // ExplainAnalyzeOperator may finish before dynamic filter stats are reported to QueryInfo
+        assertEventually(() -> assertExplainAnalyze(
+                "EXPLAIN ANALYZE SELECT * FROM nation a, nation b WHERE a.nationkey = b.nationkey",
+                "Dynamic filters: \n.*ranges=25, \\{\\[0], ..., \\[24]}.* collection time=\\d+.*"));
+    }
+
     @Test
     public void testExplainAnalyzeVerbose()
     {