[SPARK-25611][SPARK-25622] Improve test run time of CompressionCodecS…

…uite
apache · Oct 5, 2018 · 2d7ffa6 · 2d7ffa6
1 parent d6be46e
commit 2d7ffa6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/CompressionCodecSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/CompressionCodecSuite.scala
@@ -21,6 +21,7 @@ import java.io.File
 import java.util.Locale
 
 import scala.collection.JavaConverters._
+import scala.util.Random
 
 import org.apache.hadoop.fs.Path
 import org.apache.orc.OrcConf.COMPRESS
@@ -229,8 +230,8 @@ class CompressionCodecSuite extends TestHiveSingleton with ParquetTest with Befo
       tableCompressionCodecs: List[String])
       (assertionCompressionCodec: (Option[String], String, String, Long) => Unit): Unit = {
     withSQLConf(getConvertMetastoreConfName(format) -> convertMetastore.toString) {
-      tableCompressionCodecs.foreach { tableCompression =>
-        compressionCodecs.foreach { sessionCompressionCodec =>
+      Random.shuffle(tableCompressionCodecs).take(1).foreach { tableCompression =>
+        Random.shuffle(compressionCodecs).take(1).foreach { sessionCompressionCodec =>
           withSQLConf(getSparkCompressionConfName(format) -> sessionCompressionCodec) {
             // 'tableCompression = null' means no table-level compression
             val compression = Option(tableCompression)