錯誤使用CDC在三角洲住時表

[palzor]

你好,

我試圖使用CDC三角洲生活表,當管道運行第二次時,我得到一個錯誤:

org.apache.spark.sql.streaming。StreamingQueryException:查詢tbl_cdc [id = * * * -xx-xx-bf7e-6cb8b0deb690 runId = * * * xxxx - 4031 - ba74 b4b22be05774]終止與例外:發現一個數據更新(例如- 00000 - eedcf65d - 3 - aa0.snappy.parquet部分)在源表版本2。這是目前不支持。如果你想忽略更新,設置選項“ignoreChanges”到“真正的”。如果你想反映的數據更新,請重啟該查詢以全新的關卡目錄。

[jose_gonzalez]

嗨@Palzor喇嘛,

流媒體直播表隻能過程附加查詢;也就是說,查詢源表中插入新行。處理來自源表的更新,例如,合並和刪除,不支持。流程更新,請參閱申請變更成命令。你可以做什麼@Chris卡裏推薦。有關更多信息,請查看文檔https://docs.m.eheci.com/data-engineering/delta-live-tables/delta-live-tables-cdc.html apply-chan……