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

誤差在更新表com.databricks.sql.transaction.tahoe三角洲。DeltaUnsupportedOperationException:檢測到數據更新

桑傑
價值貢獻

你好,

我有管道。我已經更新一個文件在三角洲表已處理。現在我得到錯誤

com.databricks.sql.transaction.tahoe。δUnsupportedOperationException: Detected a data update. This is currently not supported. If you'd like to ignore updates, set the option 'ignoreChanges' to 'true'.

我已經設置ignoreChanges真實但仍然得到同樣的錯誤。

spark.readStream.format(“δ”)

.option (“ignoreChanges”,“真正的”)

.load (“/ tmp /δ/ user_events”)

問候,

桑傑

7回複7

karthik_p
尊敬的貢獻者

@Sanjay Jain,您使用的是運行時版本,上麵應該如果有更新工作必需字段,應該被下遊的消費者,請檢查下麵的文章

https://docs.m.eheci.com/structured-streaming/delta-lake.html ignore-updates-and-deletes

我用11.3 LTS。我更新一個字段,該數據被下遊的消費者。但挑戰是,我讓其他不變文件以及消費者和更新文件。

Sandeep
貢獻者三世

@Sanjay Jain你更新的文件嗎?你能詳細說明的步驟嗎?

桑傑
價值貢獻

使用合並成表

使用表格b

當匹配更新設置a.name = b.name

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

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

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

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

Baidu
map