0
Apache Flinkチェックポイント機能をステートフルな関数で使用する必要がありますか?Apache Flinkのチェックポイント機能はステートフルな関数で使用する必要がありますか?
Apache Flinkチェックポイント機能をステートフルな関数で使用する必要がありますか?Apache Flinkのチェックポイント機能はステートフルな関数で使用する必要がありますか?
あなたはそうする必要はありません。あなたの関数がStateを持たない場合は、何もチェックポイントされません。しかし、特定のビルトイン関数は独自の状態を持っていることに注意してください。 FlinkKafkaConsumer
。
しかし、もし私が.... something.map、flatmap.mapの流れを持っていれば...それは私がすでに計算したものがすべて処分されたことを意味しますか?またはチェックポイントで保存されますか? – user8215502
「Sink」に保存されていない場合は、その計算が破棄され、DAG全体を通過した最後の要素からストリームが再生されます。 –