本申請(qǐng)?zhí)岢鲆环N數(shù)據(jù)處理方法和流計(jì)算系統(tǒng)，該數(shù)據(jù)處理方法包括數(shù)據(jù)接收模塊接收到要處理的數(shù)據(jù)后，將所述數(shù)據(jù)寫入文件系統(tǒng)中，并在所述數(shù)據(jù)被寫入文件系統(tǒng)后，發(fā)送所述數(shù)據(jù)給邏輯處理模塊；邏輯處理模塊根據(jù)對(duì)數(shù)據(jù)的接收情況獲取有效數(shù)據(jù)，并且，定期對(duì)預(yù)設(shè)的檢查點(diǎn)進(jìn)行更新；以及，在發(fā)生失效轉(zhuǎn)移時(shí)，確定最新的檢查點(diǎn)，獲取與所述最新的檢查點(diǎn)對(duì)應(yīng)的有效數(shù)據(jù)，并恢復(fù)所述有效數(shù)據(jù)。該方法能夠滿足對(duì)外服務(wù)化的訴求，以及在發(fā)生失效轉(zhuǎn)移時(shí)避免數(shù)據(jù)源頭重發(fā)。