Flume 事務理解 數據丟失?

put事務 take事務 put事務步驟: doput :先將批數據寫入臨時緩衝區putlist裏面 docommit:去檢查channel裏面有沒有空位置,如果有就傳入數據,如果沒有那麼dorollback就把數據回滾到putlist裏面。 take事務步驟: dotake:將數據讀取到臨時緩衝區takelist,並將數據傳到hdfs上。 docommit :去判斷數據發送是否成功,若成功那麼清
相關文章
相關標籤/搜索