diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java index b3e5ee2d69fa..a5e5cfb52893 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java @@ -2575,8 +2575,8 @@ public void testAllAvailableTypes() assertUpdate("DROP TABLE test_all_types"); } - @Test - public void testLocalDynamicFilteringWithSelectiveBuildSizeJoin() + @Test(timeOut = 25_000) + public void testLocalDynamicFilteringWithSelectiveBuildSideJoin() { // We need to prepare tables for this test. The test is required to use tables that are backed by at lest two files Session session = Session.builder(getSession()) @@ -2597,6 +2597,7 @@ public void testLocalDynamicFilteringWithSelectiveBuildSizeJoin() session = Session.builder(getSession()) .setSystemProperty(JOIN_DISTRIBUTION_TYPE, BROADCAST.name()) + .setCatalogSessionProperty(ICEBERG_CATALOG, "dynamic_filtering_wait_timeout", "1h") .build(); ResultWithQueryId result = getDistributedQueryRunner().executeWithQueryId(