Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21751#discussion_r202191261
--- Diff:
sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/AnalysisSuite.scala
---
@@ -557,4 +558,21 @@ class AnalysisSuite extends AnalysisTest with Matchers
{
SubqueryAlias("tbl", testRelation)))
assertAnalysisError(barrier, Seq("cannot resolve '`tbl.b`'"))
}
+
+ test("SPARK-24208: analysis fails on self-join with
FlatMapGroupsInPandas") {
+ val pythonUdf = PythonUDF("pyUDF", null,
--- End diff --
Nit:
```
"pyUDF",
null,
```
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
