Description
Quick repro: Passes on Spark 1.6.x, but fails on 2.0
case class MyColumn(userId: Int, field: String) val ds = Seq(MyColumn(1, "a")).toDF ds.join(ds, Seq("userid"))
stacktrace: java.util.NoSuchElementException: None.get at scala.None$.get(Option.scala:313) at scala.None$.get(Option.scala:311) at org.apache.spark.sql.catalyst.analysis.Analyzer$$anonfun$88.apply(Analyzer.scala:1844) at org.apache.spark.sql.catalyst.analysis.Analyzer$$anonfun$88.apply(Analyzer.scala:1844)
Attachments
Issue Links
- links to