From 950f8480b9fbab5701918ac056cbf0e7c75d2fca Mon Sep 17 00:00:00 2001 From: Gaurav Sehgal Date: Tue, 19 Dec 2023 11:49:03 +0530 Subject: [PATCH] Use sf1 table for testMultipleWritersWithSkewedData --- .../java/io/trino/plugin/hive/BaseHiveConnectorTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java index a977ce6a996c..18bc7a699f55 100644 --- a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java +++ b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java @@ -4137,11 +4137,11 @@ public void testMultipleWriters() public void testMultipleWritersWithSkewedData() { try { - // We need to use large table (sf2) to see the effect. Otherwise, a single writer will write the entire + // We need to use large table (sf1) to see the effect. Otherwise, a single writer will write the entire // data before ScaledWriterScheduler is able to scale it to multiple machines. // Skewed table that will scale writers to multiple machines. - String selectSql = "SELECT t1.* FROM (SELECT *, case when orderkey >= 0 then 1 else orderkey end as join_key FROM tpch.sf2.orders) t1 " + - "INNER JOIN (SELECT orderkey FROM tpch.sf2.orders) t2 " + + String selectSql = "SELECT t1.* FROM (SELECT *, case when orderkey >= 0 then 1 else orderkey end as join_key FROM tpch.sf1.orders) t1 " + + "INNER JOIN (SELECT orderkey FROM tpch.sf1.orders) t2 " + "ON t1.join_key = t2.orderkey"; @Language("SQL") String createTableSql = "CREATE TABLE scale_writers_skewed WITH (format = 'PARQUET') AS " + selectSql; assertUpdate( @@ -4149,7 +4149,7 @@ public void testMultipleWritersWithSkewedData() .setSystemProperty("task_min_writer_count", "1") .setSystemProperty("scale_writers", "true") .setSystemProperty("task_scale_writers_enabled", "false") - .setSystemProperty("writer_scaling_min_data_processed", "1MB") + .setSystemProperty("writer_scaling_min_data_processed", "0.5MB") .setSystemProperty("join_distribution_type", "PARTITIONED") .build(), createTableSql,