你好,
我有一個火花流過程,從卡夫卡主題Azure DL讀取數據
這就是我如何實現功能合並到三角洲表。
除了同樣的話題,我有另一個流的過程,簡單地將數據寫入DL
在卡夫卡的話題,數據沒有被刪除,所以你總能從一開始初始化。
前幾天另一列添加到卡夫卡的話題
1。在合並,我不看到列添加了,即使它被設置為可選的
.option (“mergeSchema”,“真正的”)
選項(“模式”、“FAILFAST”)
2。在第二個過程開始時我跑我得到一個錯誤
畸形的記錄在記錄中發現解析。當前解析模式:FAILFAST。處理畸形的記錄為零的結果,盡可能設置選項“模式”“寬容”。
盡管在設置明確標記。選項(“模式”、“寬容”)
可能因為它是同樣的kafkatopic他們衝突的定義模式”FAILFAST嗎?
1。我怎麼使一列添加到流程合並?
2。我如何開始?
謝謝
