2017-07-12 96 views

回答

0

你不需要。如果你的函數沒有狀態,則不會有任何檢查點。但請注意,某些內置函數本身具有狀態,例如FlinkKafkaConsumer

+0

但是如果我有一個.... some.flow,flatmap.map流......這是否意味着我已經計算的所有東西都處置?還是在檢查點保存? – user8215502

+0

如果它沒有存儲在某個'Sink'中,那麼是的,這些計算將被丟棄,並且流將通過整個DAG中的最後一個元素進行重播。 –

相關問題