rocksdb memtableのサイズをflinkで設定するには？

Question

私は、rocsdbのmemtableサイズを制限したいと思います。私はいくつか質問があります： 1、taskmanager.memory.sizeの設定はrocksdb memtableのメモリ量を含んでいますか？ 2、rocksdbのmemtableサイズを設定できる設定はありますか？

Answer 1

1. RocksDBのメモリは、Flinkのメモリパラメータには含まれていません。 FlinkがRocksDB用に十分なメモリを確保していることを確認する必要があります。しかし、Flinkはステートフルオペレータのインスタンスごとに1つのRocksDBインスタンスを使用するため、これは簡単なことではありません。これは、TaskManagerあたりのRocksDBインスタンスの数が、ジョブ内のステートフルな演算子の数とこれらの演算子の並列性に依存することを意味します（各TMは演算子のほとんどの#slotsインスタンスで実行されます）。

2. RocksDBStateBackendの設定時に、任意のRocksDBパラメータを渡すことができます。