メモリ負荷解析

Dorisのデータロードは、fragmentの読み取りとchannelの書き込みという2つの段階に分かれています。fragmentとquery fragmentの実行ロジックは同じですが、Stream Loadは通常Scan Operatorのみを持ちます。Channelは主に一時的なデータ構造であるMemtableにデータを書き込み、その後Delta Writerがデータを圧縮してファイルに書き込みます。

ロードメモリビュー

どこかでLabel=load, Type=overviewのMemory Trackerの値が大きい場合、ロードメモリが多く使用されていることを意味します。

MemTrackerLimiter Label=load, Type=overview, Limit=-1.00 B(-1 B), Used=0(0 B), Peak=0(0 B)

Dorisによるメモリロードは2つの部分に分かれています。最初の部分はフラグメント実行で使用されるメモリで、2番目の部分はMemTableの構築とフラッシュプロセスで使用されるメモリです。

BEウェブページhttp://{be_host}:{be_web_server_port}/mem_tracker?type=globalで見つかるLabel=AllMemTableMemory, Parent Label=DetailsTrackerSetを持つMemory Trackerは、このBEノード上ですべてのロードタスクがMemTableを構築およびフラッシュするために使用するメモリです。エラープロセスのメモリが制限を超えるか、利用可能なメモリが不足している場合、このMemory Trackerはbe.INFOログのMemory Tracker Summaryでも確認できます。

MemTracker Label=AllMemTableMemory, Parent Label=DetailsTrackerSet, Used=25.08 MB(26303456 B), Peak=25.08 MB(26303456 B)

Load Memory Analysis

Label=AllMemTableMemoryの値が小さい場合、ロードタスクで使用されるメインメモリは実行フラグメントです。分析方法はQuery Memory Analysisと同じであるため、ここでは繰り返しません。

Label=AllMemTableMemoryの値が大きい場合、MemTableが適時にフラッシュされていない可能性があります。be.confのload_process_max_memory_limit_percentとload_process_soft_mem_limit_percentの値を減らすことを検討できます。これによりMemTableがより頻繁にフラッシュされ、メモリにキャッシュされるMemTableが少なくなりますが、書き込まれるファイル数は増加します。小さなファイルが多すぎる場合、compactionの負荷が増加します。compactionが適時でない場合、メタデータメモリが増加し、クエリが遅くなり、ファイル数が制限を超えるとロードがエラーを報告することもあります。

ロード実行プロセス中に、BEのWebページ/mem_tracker?type=loadを確認します。2つのメモリトラッカーグループLabel=MemTableManualInsertとLabel=MemTableHookFlushの値に基づいて、MemTableメモリ使用量が大きいLoadIDとTabletIDを特定できます。