Update SparkSqlParserSuite.scala

apache · Sep 4, 2020 · 2b8912e · 2b8912e
1 parent dbb4d04
commit 2b8912e
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -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", "#"),