From 294b02ba7ccbcde85a76b18948faa2dbb0d8fbcc Mon Sep 17 00:00:00 2001 From: Yimin Date: Fri, 31 Dec 2021 21:31:35 +0800 Subject: [PATCH] update --- .../spark/sql/execution/datasources/orc/OrcQuerySuite.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) 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 e9aa9adf5b915..6a91a9cfe9340 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 @@ -726,14 +726,12 @@ abstract class OrcQuerySuite extends OrcQueryTest with SharedSparkSession { }.toDF("record").repartition(1) df.write.format("orc").save(path) - withSQLConf(SQLConf.ORC_VECTORIZED_READER_NESTED_COLUMN_ENABLED.key -> "true", - SQLConf.WHOLESTAGE_MAX_NUM_FIELDS.key -> "10000") { + withSQLConf(SQLConf.ORC_VECTORIZED_READER_NESTED_COLUMN_ENABLED.key -> "true") { val readDf = spark.read.orc(path) val vectorizationEnabled = readDf.queryExecution.executedPlan.find { case scan @ (_: FileSourceScanExec | _: BatchScanExec) => scan.supportsColumnar case _ => false }.isDefined - assert(vectorizationEnabled) checkAnswer(readDf, df) } }