From 9cec75e1012c7d7bd9751b7c0982ea7046363727 Mon Sep 17 00:00:00 2001 From: ashahid Date: Fri, 28 Feb 2025 14:33:45 -0800 Subject: [PATCH] SPARK-51016. fixed test failures after refactoring --- .../spark/sql/catalyst/expressions/namedExpressions.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala index 9c365d7565a25..4b8762a4719e1 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/namedExpressions.scala @@ -196,7 +196,7 @@ case class Alias(child: Expression, name: String)( override def toAttribute: Attribute = { if (resolved) { - AttributeReference(name, child.dataType, child.nullable)(exprId, qualifier, + AttributeReference(name, child.dataType, child.nullable, metadata)(exprId, qualifier, this.hasIndeterminism) } else { UnresolvedAttribute.quoted(name) @@ -367,7 +367,7 @@ case class AttributeReference( } override protected final def otherCopyArgs: Seq[AnyRef] = { - exprId :: qualifier :: Nil + exprId :: qualifier :: Boolean.box(hasIndeterminism) :: Nil } /** Used to signal the column used to calculate an eventTime watermark (e.g. a#1-T{delayMs}) */