We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2bf402b commit 37a7889Copy full SHA for 37a7889
sql/core/src/test/scala/org/apache/spark/sql/GroupedDatasetSuite.scala
@@ -93,16 +93,4 @@ class GroupedDatasetSuite extends QueryTest with SharedSQLContext {
93
}
94
datasetWithUDF.unpersist(true)
95
96
-
97
- test("SPARK-24208: analysis fails on self-join with FlatMapGroupsInPandas") {
98
- val df = datasetWithUDF.groupBy("s").flatMapGroupsInPandas(PythonUDF(
99
- "pyUDF",
100
- null,
101
- StructType(Seq(StructField("s", LongType))),
102
- Seq.empty,
103
- PythonEvalType.SQL_GROUPED_MAP_PANDAS_UDF,
104
- true))
105
- val df1 = df.alias("temp0").join(df.alias("temp1"), $"temp0.s" === $"temp1.s")
106
- df1.queryExecution.assertAnalyzed()
107
- }
108
0 commit comments