當模式改變而讀寫流,將自動模式變化是由火花
還是我們需要包含的選項(mergeschema = True) ?
例如:
df.writeStream
.option (“mergeSchema”,“真正的”)
.format(“δ”)
.outputMode(“追加”)
.option(“路徑”、“/數據/”)
.option (“checkpointLocation”、“檢查點/”)
.start ()
.awaitTermination ()
包括選項(mergeschema = True)仍然拋出錯誤:
錯誤:模式匹配檢測到寫作時三角洲表
要啟用模式遷移,請設置:
”。選項(“mergeSchema”,“真正的”)”。
做任何額外的選項/更改上麵的查詢需要做嗎?你能建議解決這個問題嗎?
mergeSchema不支持所有操作。在某些情況下.option (“overwriteSchema”,“真正的”)是必要的。MergeSchema不支持:
更多關於這個話題//m.eheci.com/blog/2019/09/24/diving-into-delta-lake-schema-enforcement-evolution.html