fix

apache · Mar 13, 2024 · d6858fa · d6858fa
1 parent 87b5bb4
commit d6858fa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala b/spark/src/main/scala/org/apache/comet/CometSparkSessionExtensions.scala
@@ -235,7 +235,7 @@ class CometSparkSessionExtensions
           val nativeOp = QueryPlanSerde.operator2Proto(op).get
           CometScanWrapper(nativeOp, op)
 
-        case leaf: LeafExecNode if applyRowToColumnar(leaf) =>
+        case leaf: LeafExecNode if applyRowToColumnar(conf, leaf) =>
           val cometOp = CometRowToColumnarExec(leaf)
           val nativeOp = QueryPlanSerde.operator2Proto(cometOp).get
           CometSinkPlaceHolder(nativeOp, leaf, cometOp)