Description
Currently, Spark doesn't support LeafRunnableCommand as sub query.
Because the LeafRunnableCommand always output GenericInternalRow and some node(e.g. SortExec, AdaptiveExecutionExec, WholeCodegenExec) will convert GenericInternalRow to UnsafeRow. So will causes error as follows:
java.lang.ClassCastException
org.apache.spark.sql.catalyst.expressions.GenericInternalRow cannot be cast to org.apache.spark.sql.catalyst.expressions.UnsafeRow
Attachments
Issue Links
- links to
(7 links to)