revert to previous partition spec

himadripal · Feb 28, 2024 · a1b875e · a1b875e
1 parent 97eed0a
commit a1b875e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/connector/KeyGroupedPartitioningSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/connector/KeyGroupedPartitioningSuite.scala
@@ -1484,7 +1484,7 @@ class KeyGroupedPartitioningSuite extends DistributionAndOrderingSuiteBase {
 
         val partition1 = Array(identity("store_id"),
           bucket(table1buckets, "dept_id"))
-        val partition2 = Array(identity("store_id"),
+        val partition2 = Array(bucket(3, "store_id"),
           bucket(table2buckets, "dept_id"))
 
         createTable(table1, schema2, partition1)