取消
顯示的結果
而不是尋找
你的意思是:

pyspark三角洲表模式演化

zyang
貢獻者

我使用的模式演化三角洲表和代碼寫在磚筆記本。

df。寫.format(“δ”).mode .option(“追加”)(“mergeSchema”,“真正的”).partitionBy(“日期”).save(路徑)

但我仍然得到了下麵的錯誤。是正確的定義模式和啟用mergeSchema在同一時間嗎?

AnalysisException:指定的模式不匹配現有模式的路徑。= = = =根——:指定字符串(nullable = false)——B:字符串(nullable = true)——C:現有長(可空= true) = = = =根——一個:字符串(nullable = true)——B:字符串(nullable = true)——C:長(可空= true) = = = =差異——字段非空現有模式中指定的模式,但可以為空。如果你的目的是保持現有模式,您可以省略這個模式從create table命令。否則請確保模式匹配。

1回複1

Noopur_Nigam
重視貢獻二世

你好楊@z請提供df創建代碼理解完整的異常和場景。

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map