2017-07-12 9 views

答えて

0

あなたはそうする必要はありません。あなたの関数がStateを持たない場合は、何もチェックポイントされません。しかし、特定のビルトイン関数は独自の状態を持っていることに注意してください。 FlinkKafkaConsumer

+0

しかし、もし私が.... something.map、flatmap.mapの流れを持っていれば...それは私がすでに計算したものがすべて処分されたことを意味しますか?またはチェックポイントで保存されますか? – user8215502

+0

「Sink」に保存されていない場合は、その計算が破棄され、DAG全体を通過した最後の要素からストリームが再生されます。 –

関連する問題