diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/client/HiveClientVersions.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/client/HiveClientVersions.scala index d48d70f7d4e7..6648c04a4c50 100644 --- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/client/HiveClientVersions.scala +++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/client/HiveClientVersions.scala @@ -22,7 +22,10 @@ import scala.collection.immutable.IndexedSeq import org.apache.commons.lang3.{JavaVersion, SystemUtils} private[client] trait HiveClientVersions { - protected val versions = if (SystemUtils.isJavaVersionAtLeast(JavaVersion.JAVA_9)) { + private val testVersions = sys.env.get("SPARK_TEST_HIVE_CLIENT_VERSIONS") + protected val versions = if (testVersions.nonEmpty) { + testVersions.get.split(",").map(_.trim).filter(_.nonEmpty).toIndexedSeq + } else if (SystemUtils.isJavaVersionAtLeast(JavaVersion.JAVA_9)) { IndexedSeq("2.0", "2.1", "2.2", "2.3", "3.0", "3.1") } else { IndexedSeq("0.12", "0.13", "0.14", "1.0", "1.1", "1.2", "2.0", "2.1", "2.2", "2.3", "3.0",