0 你不需要。如果你的函數沒有狀態,則不會有任何檢查點。但請注意,某些內置函數本身具有狀態,例如FlinkKafkaConsumer。 來源 2017-07-13 07:38:26 +0 但是如果我有一個.... some.flow,flatmap.map流......這是否意味着我已經計算的所有東西都處置?還是在檢查點保存? – user8215502 +0 如果它沒有存儲在某個'Sink'中,那麼是的,這些計算將被丟棄,並且流將通過整個DAG中的最後一個元素進行重播。 –
但是如果我有一個.... some.flow,flatmap.map流......這是否意味着我已經計算的所有東西都處置?還是在檢查點保存? – user8215502
如果它沒有存儲在某個'Sink'中,那麼是的,這些計算將被丟棄,並且流將通過整個DAG中的最後一個元素進行重播。 –