diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcQuerySuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcQuerySuite.scala index 2d6978a81024..8bc92f8d57ad 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcQuerySuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcQuerySuite.scala @@ -776,7 +776,7 @@ abstract class OrcQuerySuite extends OrcQueryTest with SharedSparkSession { } :+ (null, null) withOrcFile(data) { file => - withAllOrcReaders { + withAllNativeOrcReaders { checkAnswer(spark.read.orc(file), data.toDF().collect()) } } @@ -799,7 +799,7 @@ abstract class OrcQuerySuite extends OrcQueryTest with SharedSparkSession { withTempPath { file => val df = spark.createDataFrame(sparkContext.parallelize(data), actualSchema) df.write.orc(file.getCanonicalPath) - withAllOrcReaders { + withAllNativeOrcReaders { val msg = intercept[SparkException] { spark.read.schema(providedSchema).orc(file.getCanonicalPath).collect() }.getMessage @@ -825,7 +825,7 @@ abstract class OrcQuerySuite extends OrcQueryTest with SharedSparkSession { withTempPath { file => val df = spark.createDataFrame(sparkContext.parallelize(data), actualSchema) df.write.orc(file.getCanonicalPath) - withAllOrcReaders { + withAllNativeOrcReaders { checkAnswer(spark.read.schema(providedSchema).orc(file.getCanonicalPath), answer) } } diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcTest.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcTest.scala index cd87374e8574..96932de3275b 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcTest.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/orc/OrcTest.scala @@ -143,7 +143,7 @@ abstract class OrcTest extends QueryTest with FileBasedDataSourceTest with Befor spark.read.orc(file.getAbsolutePath) } - def withAllOrcReaders(code: => Unit): Unit = { + def withAllNativeOrcReaders(code: => Unit): Unit = { // test the row-based reader withSQLConf(SQLConf.ORC_VECTORIZED_READER_ENABLED.key -> "false")(code) // test the vectorized reader