Minor Description
In the following example,
val rdd = ... // two columns:
{key, value}val derivedRDD = rdd.distinct().limit(1)
sql("explain select * from rdd inner join derivedRDD on rdd.key = derivedRDD.key")
The inner join executes incorrectly since the two keys end up with the same attribute id after analysis.
Attachments
Issue Links
- links to
