Skip to content

Commit e2b64be

Browse files
committed
Update basicOperators.scala
1 parent 4dd453e commit e2b64be

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/basicOperators.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -214,6 +214,6 @@ case class Intersect(left: SparkPlan, right: SparkPlan) extends BinaryNode {
214214
override def output = children.head.output
215215

216216
override def execute() = {
217-
left.execute().intersection(right.execute())
217+
left.execute().map(_.copy()).intersection(right.execute().map(_.copy()))
218218
}
219219
}

0 commit comments

Comments
 (0)