Skip to content

Commit 922624e

Browse files
committed
flip create unsafe projetion
1 parent 0b3db01 commit 922624e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/ExistingRDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,7 @@ case class OneRowRelationExec() extends LeafExecNode
356356

357357
override def inputRDD: RDD[InternalRow] = rdd
358358

359-
override protected val createUnsafeProjection: Boolean = true
359+
override protected val createUnsafeProjection: Boolean = false
360360

361361
override protected def doCanonicalize(): SparkPlan = {
362362
super.doCanonicalize().asInstanceOf[OneRowRelationExec].copy()

0 commit comments

Comments
 (0)