1

という名前のビデオを見ましたManaging State in Apache Flink - Tzu-Li (Gordon) Tai。このビデオでは、分散ファイル システムでデータを保存します。

Flink チェックポイント用にローカル ファイル システムを構成するとどうなるのだろうか?

例えば:

env.setStateBackend(new RocksDBStateBackend(getString("flie:///tmp/checkpoints"), true));

Flink クラスタのすべてのノードが独自のデータを保持すると仮定します。うまくいくでしょうか?

4

1 に答える 1