dataNode関連コンフィギュレーション
dataNode.dataSync.flowGraph.maxQueueLength
| 説明 | デフォルト値 |
|---|---|
| フローグラフタスクキューの最大長 | 16 |
dataNode.dataSync.flowGraph.maxParallelism
| 説明 | デフォルト値 |
|---|---|
| フローグラフ内で並列に実行されるタスクの最大数 | 1024 |
dataNode.dataSync.maxParallelSyncMgrTasks
| 説明 | デフォルト値 |
|---|---|
| グローバルなデータノード同期mgrの最大同時同期タスク数 | 256 |
dataNode.dataSync.skipMode.enable
| 説明 | デフォルト値 |
|---|---|
| CPU使用量を減らすためにタイムティック・メッセージをスキップする。 | 真 |
dataNode.dataSync.skipMode.skipNum
| 説明 | デフォルト値 |
|---|---|
| n個のレコードをスキップするごとに1個消費 | 4 |
dataNode.dataSync.skipMode.coldTime
| 説明 | デフォルト値 |
|---|---|
| x 秒間タイムティックの msg だけがあった後、スキップモードをオンにする。 | 60 |
dataNode.segment.insertBufSize
| 説明 | デフォルト値 |
|---|---|
|
|
16777216 |
dataNode.segment.deleteBufBytes
| 説明 | デフォルト値 |
|---|---|
| デフォルトは 16MB である。 | 16777216 |
dataNode.segment.syncPeriod
| 説明 | デフォルト値 |
|---|---|
| バッファが空でない場合にセグメントを同期する期間。 | 600 |
dataNode.memory.forceSyncEnable
| 説明 | デフォルト値 |
|---|---|
| メモリ使用量が多すぎる場合に強制的に同期させるにはtrueを設定する | true |
dataNode.memory.forceSyncSegmentNum
| 説明 | デフォルト値 |
|---|---|
| 同期するセグメント数。 | 1 |
dataNode.memory.checkInterval
| 説明 | デフォルト値 |
|---|---|
| データノードのメモリ使用量をチェックする間隔。 | 3000 |
dataNode.memory.forceSyncWatermark
| 説明 | デフォルト値 |
|---|---|
| この透かしに達すると、セグメントが同期される。 | 0.5 |
dataNode.channel.workPoolSize
| 説明 | デフォルト値 |
|---|---|
|
|
-1 |
dataNode.channel.updateChannelCheckpointMaxParallel
| 説明 | デフォルト値 |
|---|---|
|
|
10 |
dataNode.channel.updateChannelCheckpointInterval
| 説明 | デフォルト値 |
|---|---|
| データノードが各チャネルのチェックポイントを更新する間隔(秒) | 60 |
dataNode.channel.updateChannelCheckpointRPCTimeout
| 説明 | デフォルト値 |
|---|---|
| UpdateChannelCheckpoint RPC 呼び出しのタイムアウト時間 (秒) | 20 |
dataNode.channel.maxChannelCheckpointsPerPRC
| 説明 | デフォルト値 |
|---|---|
| UpdateChannelCheckpoint RPCごとのチャネル・チェックポイントの最大数。 | 128 |
dataNode.channel.channelCheckpointUpdateTickInSeconds
| 説明 | デフォルト値 |
|---|---|
| チャネル・チェックポイント・アップデータが更新を実行する頻度を秒単位で指定します。 | 10 |
dataNode.import.maxConcurrentTaskNum
| 説明 | デフォルト値 |
|---|---|
| データノードで同時に実行できるインポート/プレインポート・タスクの最大数。 | 16 |
dataNode.import.maxImportFileSizeInGB
| 説明 | デフォルト値 |
|---|---|
| インポート・ファイルの最大ファイル・サイズ(GB単位)。インポート・ファイルとは、行ベース・ファイルまたは列ベース・ファイルのセットを指します。 | 16 |
dataNode.import.readBufferSizeInMB
| 説明 | デフォルト値 |
|---|---|
| インポート中にデータノードがチャンク・マネージャから読み込むデータ・ブロック・サイズ(MB単位)。 | 16 |
dataNode.import.maxTaskSlotNum
| 説明 | デフォルト値 |
|---|---|
| 各インポート/プレインポート・タスクが占有するスロットの最大数。 | 16 |
dataNode.compaction.levelZeroBatchMemoryRatio
| 説明 | デフォルト値 |
|---|---|
| バッチ・モードで実行されるレベルゼロ・コンパクションの空きメモリの最小メモリ比率 | 0.5 |
dataNode.compaction.levelZeroMaxBatchSize
| 説明 | デフォルト値 |
|---|---|
| 最大バッチサイズ(Max batch size) L0 コンパクションを実行する際の、バッチ内の L1/L2 セグメントの最大数を示す。デフォルトは -1、1 未満の値は制限なしを意味する。有効範囲:>= 1. | -1 |
dataNode.compaction.useMergeSort
| 説明 | デフォルト値 |
|---|---|
| mixCompaction実行時にmergeSortモードを有効にするかどうか。 | false |
dataNode.compaction.maxSegmentMergeSort
| 説明 | デフォルト値 |
|---|---|
| mergeSort モードでマージされるセグメントの最大数。 | 30 |
dataNode.gracefulStopTimeout
| 説明 | デフォルト値 |
|---|---|
| 秒。グレースフルストップなしでノードを強制停止する。 | 1800 |
dataNode.slot.slotCap
| 説明 | デフォルト値 |
|---|---|
| データノード上で同時に実行できるタスク(コンパクション、インポートなど)の最大数 | 16 |
dataNode.clusteringCompaction.memoryBufferRatio
| 説明 | デフォルト値 |
|---|---|
| クラスタリング・コンパクションのメモリ・バッファの比率。閾値より大きいデータはストレージにフラッシュされます。 | 0.3 |
dataNode.clusteringCompaction.workPoolSize
| 説明 | デフォルト値 |
|---|---|
| 1つのクラスタリング圧縮ジョブのワーカープールサイズ。 | 8 |
dataNode.bloomFilterApplyParallelFactor
| 説明 | デフォルト値 |
|---|---|
| ブルームフィルタにpkを適用する際の並列係数、デフォルトは4*CPU_CORE_NUM | 4 |
dataNode.storage.deltalog
| 説明 | デフォルト値 |
|---|---|
| deltalogフォーマット、オプション:[json, parquet] | json |
dataNode.ip
| 説明 | デフォルト値 |
|---|---|
| dataNodeのTCP/IPアドレス。指定されていない場合は、最初のユニキャスト可能なアドレスを使用する。 |
dataNode.port
| 説明 | デフォルト値 |
|---|---|
| dataNodeのTCPポート | 21124 |
dataNode.grpc.serverMaxSendSize
| 説明 | デフォルト値 |
|---|---|
| dataNodeが送信できる各RPCリクエストの最大サイズ、単位:バイト | 536870912 |
dataNode.grpc.serverMaxRecvSize
| 説明 | デフォルト値 |
|---|---|
| dataNodeが受信できる各RPCリクエストの最大サイズ、単位:バイト | 268435456 |
dataNode.grpc.clientMaxSendSize
| 説明 | デフォルト値 |
|---|---|
| dataNode上のクライアントが送信できる各RPCリクエストの最大サイズ、単位:バイト | 268435456 |
dataNode.grpc.clientMaxRecvSize
| 説明 | デフォルト値 |
|---|---|
| dataNode上のクライアントが受信できる各RPCリクエストの最大サイズ、単位:バイト | 536870912 |