Update FilterPushdownSuite.scala

apache · Nov 9, 2020 · 803bf0a · 803bf0a
1 parent c3ec848
commit 803bf0a
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/...catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/FilterPushdownSuite.scala b/...catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/FilterPushdownSuite.scala
@@ -1212,28 +1212,22 @@ class FilterPushdownSuite extends PlanTest {
   test("push down predicate through expand") {
     val input = LocalRelation('a.int, 'b.string, 'c.double)
     val query =
-      Aggregate(
-        Seq('a, 'b),
-        Seq(sum('c).as("sum")),
         Filter('a > 1,
           Expand(
             Seq(
               Seq('a, 'b, 'c, Literal.create(null, StringType), 1),
               Seq('a, 'b, 'c, 'a, 2)),
             Seq('a, 'b, 'c),
-            input))).analyze
+            input)).analyze
     val optimized = Optimize.execute(query)
 
     val expected =
-      Aggregate(
-        Seq('a, 'b),
-        Seq(sum('c).as("sum")),
         Expand(
           Seq(
             Seq('a, 'b, 'c, Literal.create(null, StringType), 1),
             Seq('a, 'b, 'c, 'a, 2)),
           Seq('a, 'b, 'c),
-          Filter('a > 1, input))).analyze
+          Filter('a > 1, input)).analyze
 
     comparePlans(optimized, expected)
   }