diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlParserSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlParserSuite.scala index af9088003f3b0..cf01afdb36d00 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlParserSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/SparkSqlParserSuite.scala @@ -352,12 +352,13 @@ class SparkSqlParserSuite extends AnalysisTest { |FROM testData """.stripMargin, ScriptTransformation( - Seq('a, 'b, 'c), + Seq(UnresolvedStar(None)), "cat", Seq(AttributeReference("a", StringType)(), AttributeReference("b", StringType)(), AttributeReference("c", StringType)()), - UnresolvedRelation(TableIdentifier("testData")), + Project(Seq('a, 'b, 'c), + UnresolvedRelation(TableIdentifier("testData"))), ScriptInputOutputSchema( Seq(("TOK_TABLEROWFORMATFIELD", ","), ("TOK_TABLEROWFORMATCOLLITEMS", "#"),