diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala index 5ef3c9d3ff628..5fe5dc373718d 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala @@ -32,7 +32,7 @@ case class ScriptTransformation( child: LogicalPlan, ioschema: ScriptInputOutputSchema) extends UnaryNode { @transient - override lazy val references: AttributeSet = AttributeSet(child.output.flatMap(_.references)) + override lazy val references: AttributeSet = AttributeSet(child.output) override protected def withNewChildInternal(newChild: LogicalPlan): ScriptTransformation = copy(child = newChild)