Update ScriptTransformation.scala

apache · Apr 20, 2021 · adea65b · adea65b
1 parent 0af2f3d
commit adea65b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...yst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ScriptTransformation.scala b/...yst/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)