use single threaded tests to reduce flakiness

prestodb · Mar 8, 2024 · 0836d83 · 0836d83
1 parent 14e81ae
commit 0836d83
Show file tree

Hide file tree

Showing 10 changed files with 12 additions and 2 deletions.
diff --git a/...src/test/java/com/facebook/presto/plugin/clickhouse/TestClickHouseDistributedQueries.java b/...src/test/java/com/facebook/presto/plugin/clickhouse/TestClickHouseDistributedQueries.java
@@ -44,6 +44,7 @@
 import static org.testng.Assert.assertFalse;
 import static org.testng.Assert.assertTrue;
 
+@Test(singleThreaded = true)
 public class TestClickHouseDistributedQueries
             extends AbstractTestDistributedQueries
 {

diff --git a/presto-hive/src/test/java/com/facebook/presto/hive/TestHiveDistributedQueries.java b/presto-hive/src/test/java/com/facebook/presto/hive/TestHiveDistributedQueries.java
@@ -34,6 +34,7 @@
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertTrue;
 
+@Test(singleThreaded = true)
 public class TestHiveDistributedQueries
         extends AbstractTestDistributedQueries
 {

diff --git a/.../java/com/facebook/presto/hive/TestHiveDistributedQueriesWithExchangeMaterialization.java b/.../java/com/facebook/presto/hive/TestHiveDistributedQueriesWithExchangeMaterialization.java
@@ -32,6 +32,7 @@
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertThrows;
 
+@Test(singleThreaded = true)
 public class TestHiveDistributedQueriesWithExchangeMaterialization
         extends AbstractTestDistributedQueries
 {

diff --git a/.../java/com/facebook/presto/hive/TestHiveDistributedQueriesWithOptimizedRepartitioning.java b/.../java/com/facebook/presto/hive/TestHiveDistributedQueriesWithOptimizedRepartitioning.java
@@ -16,11 +16,13 @@
 import com.facebook.presto.testing.QueryRunner;
 import com.facebook.presto.tests.AbstractTestDistributedQueries;
 import com.google.common.collect.ImmutableMap;
+import org.testng.annotations.Test;
 
 import java.util.Optional;
 
 import static io.airlift.tpch.TpchTable.getTables;
 
+@Test(singleThreaded = true)
 public class TestHiveDistributedQueriesWithOptimizedRepartitioning
         extends AbstractTestDistributedQueries
 {

diff --git a/...-hive/src/test/java/com/facebook/presto/hive/TestHiveDistributedQueriesWithThriftRpc.java b/...-hive/src/test/java/com/facebook/presto/hive/TestHiveDistributedQueriesWithThriftRpc.java
@@ -16,11 +16,13 @@
 import com.facebook.presto.testing.QueryRunner;
 import com.facebook.presto.tests.AbstractTestDistributedQueries;
 import com.google.common.collect.ImmutableMap;
+import org.testng.annotations.Test;
 
 import java.util.Optional;
 
 import static io.airlift.tpch.TpchTable.getTables;
 
+@Test(singleThreaded = true)
 public class TestHiveDistributedQueriesWithThriftRpc
         extends AbstractTestDistributedQueries
 {

diff --git a/presto-hive/src/test/java/com/facebook/presto/hive/TestHivePushdownDistributedQueries.java b/presto-hive/src/test/java/com/facebook/presto/hive/TestHivePushdownDistributedQueries.java
@@ -26,6 +26,7 @@
 import static io.airlift.tpch.TpchTable.getTables;
 import static org.testng.Assert.assertEquals;
 
+@Test(singleThreaded = true)
 public class TestHivePushdownDistributedQueries
         extends AbstractTestDistributedQueries
 {

diff --git a/presto-hive/src/test/java/com/facebook/presto/hive/TestParquetDistributedQueries.java b/presto-hive/src/test/java/com/facebook/presto/hive/TestParquetDistributedQueries.java
@@ -30,6 +30,7 @@
 import static io.airlift.tpch.TpchTable.getTables;
 import static org.testng.Assert.assertEquals;
 
+@Test(singleThreaded = true)
 public class TestParquetDistributedQueries
         extends AbstractTestDistributedQueries
 {

diff --git a/presto-iceberg/src/test/java/com/facebook/presto/iceberg/IcebergDistributedTestBase.java b/presto-iceberg/src/test/java/com/facebook/presto/iceberg/IcebergDistributedTestBase.java
@@ -112,6 +112,7 @@
 import static java.util.Objects.requireNonNull;
 import static org.testng.Assert.assertTrue;
 
+@Test(singleThreaded = true)
 public class IcebergDistributedTestBase
         extends AbstractTestDistributedQueries
 {

diff --git a/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlDistributedQueries.java b/presto-mysql/src/test/java/com/facebook/presto/plugin/mysql/TestMySqlDistributedQueries.java
@@ -33,7 +33,7 @@
 import static com.facebook.presto.testing.assertions.Assert.assertEquals;
 import static java.util.concurrent.TimeUnit.SECONDS;
 
-@Test
+@Test(singleThreaded = true)
 public class TestMySqlDistributedQueries
         extends AbstractTestDistributedQueries
 {

diff --git a/...c/test/java/com/facebook/presto/plugin/singlestore/TestSingleStoreDistributedQueries.java b/...c/test/java/com/facebook/presto/plugin/singlestore/TestSingleStoreDistributedQueries.java
@@ -29,7 +29,7 @@
 import static java.util.stream.IntStream.range;
 import static org.testng.Assert.assertTrue;
 
-@Test
+@Test(singleThreaded = true)
 public class TestSingleStoreDistributedQueries
         extends AbstractTestDistributedQueries
 {