Description
This notebook demonstrates the bug.
The obvious issue is that nested UDTs are not supported if the UDT is Python-only. Looking at the exception thrown, this seems to be because the encoder on the Java end tries to encode the UDT as a Java class, which doesn't exist for the [[PythonOnlyUDT]].
Attachments
Issue Links
- relates to
-
SPARK-16062 PySpark SQL python-only UDTs don't work well
- Resolved
-
SPARK-23848 Structured Streaming fails with nested UDTs
- Resolved
- links to