avoid flaky test

apache · Sep 23, 2020 · edd8aa5 · edd8aa5
1 parent fdab8b9
commit edd8aa5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/sources/InsertSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/sources/InsertSuite.scala
@@ -849,7 +849,7 @@ class InsertSuite extends DataSourceTest with SharedSparkSession {
             """
               |create table dynamic_partition_bucket(i int, part1 int, part2 int) using parquet
               |partitioned by (part1, part2)
-              |clustered by (i) into 3 buckets
+              |clustered by (i) into 5 buckets
             """.stripMargin)
           val e3 = intercept[SparkException] {
             // we use same partition (part1=2/part2=2) to make total partitions less then 3

diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/InsertSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/InsertSuite.scala
@@ -876,7 +876,7 @@ class InsertSuite extends QueryTest with TestHiveSingleton with BeforeAndAfter
             """
               |create table hive_dynamic_partition_bucket(i int) stored as parquet
               |partitioned by (part1 int, part2 int)
-              |clustered by (i) into 3 buckets
+              |clustered by (i) into 5 buckets
             """.stripMargin)
           val e3 = intercept[SparkException] {
             // we use same partition (part1=2/part2=2) to make total partitions less then 3