という名前のビデオを見ましたManaging State in Apache Flink - Tzu-Li (Gordon) Tai
。このビデオでは、分散ファイル システムでデータを保存します。
Flink チェックポイント用にローカル ファイル システムを構成するとどうなるのだろうか?
例えば:
env.setStateBackend(new RocksDBStateBackend(getString("flie:///tmp/checkpoints"), true));
Flink クラスタのすべてのノードが独自のデータを保持すると仮定します。うまくいくでしょうか?