Fix compilation after merge master

G-Research · Sep 2, 2024 · 475e371 · 475e371
1 parent 7e465a6
commit 475e371
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala b/sql/core/src/main/scala/org/apache/spark/sql/KeyValueGroupedDataset.scala
@@ -26,6 +26,7 @@ import org.apache.spark.sql.catalyst.expressions.{Ascending, Attribute, Expressi
 import org.apache.spark.sql.catalyst.plans.logical._
 import org.apache.spark.sql.execution.QueryExecution
 import org.apache.spark.sql.expressions.ReduceAggregator
+import org.apache.spark.sql.internal.ExpressionColumnNode
 import org.apache.spark.sql.internal.TypedAggUtils.{aggKeyColumn, withInputType}
 import org.apache.spark.sql.streaming.{GroupState, GroupStateTimeout, OutputMode, StatefulProcessor, StatefulProcessorWithInitialState, TimeMode}
 
@@ -1213,7 +1214,7 @@ class KeyValueGroupedDataset[K, V] private[sql](
   private def scopeTypedColumn(
       scope: Seq[Attribute])(
       typedCol: TypedColumn[_, _]): TypedColumn[_, _] =
-    new TypedColumn(ScopedExpression(typedCol.expr, scope), typedCol.encoder)
+    new TypedColumn(ExpressionColumnNode(ScopedExpression(typedCol.expr, scope)), typedCol.encoder)
 
 
   override def toString: String = {