以下のように 2 つのテーブルを結合しています。プログラムはログ行の下で停止し、先に進みません。
INFO SparkContext: ジョブの開始: Exchange.scala:79 の RangePartitioner
問題と考えられる解決策は何ですか? 問題は列の数ですか?任意の提案をいただければ幸いです。
テーブル 1 には 400 行と 450 列があります テーブル 2 には 1000 行と 100 列があります
val table1= myTable1.as('table1)
val table2= myTable2.as('table2)
val results= table1.join(table2,LeftOuter,Some("table1.Id".attr === "table2.id".attr ))
println(results.count())