We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e188c66 commit b9f29c8Copy full SHA for b9f29c8
1 file changed
spark/src/main/scala/org/apache/comet/rules/CometScanRule.scala
@@ -307,6 +307,8 @@ case class CometScanRule(session: SparkSession)
307
if (s.isCometEnabled && schemaSupported) {
308
// When reading from Iceberg, we automatically enable type promotion
309
SQLConf.get.setConfString(COMET_SCHEMA_EVOLUTION_ENABLED.key, "true")
310
+ // When reading from Iceberg, we automatically disable native columnar to row
311
+ SQLConf.get.setConfString(COMET_NATIVE_COLUMNAR_TO_ROW_ENABLED.key, "false")
312
CometBatchScanExec(
313
scanExec.clone().asInstanceOf[BatchScanExec],
314
runtimeFilters = scanExec.runtimeFilters)
0 commit comments