diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java index 44d840408ace..de022f8fcbec 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java @@ -375,7 +375,7 @@ private void runOptimizeDuringWriteOperations(boolean useSmallFiles) { int threads = 5; int deletionThreads = threads - 1; - int rows = 20; + int rows = 12; int rowsPerThread = rows / deletionThreads; CyclicBarrier barrier = new CyclicBarrier(threads); @@ -383,7 +383,7 @@ private void runOptimizeDuringWriteOperations(boolean useSmallFiles) // Slow down the delete operations so optimize is more likely to complete String blackholeTable = "blackhole_table_" + randomNameSuffix(); - assertUpdate("CREATE TABLE blackhole.default.%s (a INT, b INT) WITH (split_count = 1, pages_per_split = 1, rows_per_page = 1, page_processing_delay = '1s')".formatted(blackholeTable)); + assertUpdate("CREATE TABLE blackhole.default.%s (a INT, b INT) WITH (split_count = 1, pages_per_split = 1, rows_per_page = 1, page_processing_delay = '3s')".formatted(blackholeTable)); try (TestTable table = new TestTable( getQueryRunner()::execute,