Skip to content

Commit b25e491

Browse files
committed
remove one more test
1 parent 8ffc9eb commit b25e491

File tree

1 file changed

+0
-13
lines changed

1 file changed

+0
-13
lines changed

sql/core/src/test/scala/org/apache/spark/sql/DataFrameAggregateSuite.scala

Lines changed: 0 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -957,17 +957,4 @@ class DataFrameAggregateSuite extends QueryTest
957957
assert(error.message.contains("function count_if requires boolean type"))
958958
}
959959
}
960-
961-
test("calendar interval agg support hash aggregate") {
962-
val df1 = Seq((1, "1 day"), (2, "2 day"), (3, "3 day"), (3, null)).toDF("a", "b")
963-
val df2 = df1.select(avg($"b" cast CalendarIntervalType))
964-
checkAnswer(df2, Row(new CalendarInterval(0, 2, 0)) :: Nil)
965-
assert(find(df2.queryExecution.executedPlan)(_.isInstanceOf[HashAggregateExec]).isDefined)
966-
val df3 = df1.groupBy($"a").agg(avg($"b" cast CalendarIntervalType))
967-
checkAnswer(df3,
968-
Row(1, new CalendarInterval(0, 1, 0)) ::
969-
Row(2, new CalendarInterval(0, 2, 0)) ::
970-
Row(3, new CalendarInterval(0, 3, 0)) :: Nil)
971-
assert(find(df3.queryExecution.executedPlan)(_.isInstanceOf[HashAggregateExec]).isDefined)
972-
}
973960
}

0 commit comments

Comments
 (0)