Конфигурации, связанные с dataNode
dataNode.dataSync.flowGraph.maxQueueLength
| Описание | Значение по умолчанию |
|---|---|
| Максимальная длина очереди задач в графе потока | 16 |
dataNode.dataSync.flowGraph.maxParallelism
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество параллельно выполняемых задач в графе потока | 1024 |
dataNode.dataSync.maxParallelSyncMgrTasks
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество одновременных задач синхронизации для datanode sync mgr в глобальном масштабе | 256 |
dataNode.dataSync.skipMode.enable
| Описание | Значение по умолчанию |
|---|---|
| Поддержка пропуска некоторых сообщений timetick для снижения нагрузки на процессор | true |
dataNode.dataSync.skipMode.skipNum
| Описание | Значение по умолчанию |
|---|---|
| Потреблять по одной за каждые n пропущенных записей | 4 |
dataNode.dataSync.skipMode.coldTime
| Описание | Значение по умолчанию |
|---|---|
| Включить режим пропуска после того, как в течение x секунд были только сообщения о таймлапсе | 60 |
dataNode.segment.insertBufSize
| Описание | Значение по умолчанию |
|---|---|
|
|
16777216 |
dataNode.segment.deleteBufBytes
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер буфера в байтах для промывки del для одного канала, по умолчанию 16 МБ. | 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
| Описание | Значение по умолчанию |
|---|---|
| таймаут в секундах для вызова RPC UpdateChannelCheckpoint | 20 |
dataNode.channel.maxChannelCheckpointsPerPRC
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество контрольных точек канала для одного RPC UpdateChannelCheckpoint. | 128 |
dataNode.channel.channelCheckpointUpdateTickInSeconds
| Описание | Значение по умолчанию |
|---|---|
| Частота, в секундах, с которой программа обновления контрольных точек канала выполняет обновления. | 10 |
dataNode.import.maxConcurrentTaskNum
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество задач импорта/преимпорта, разрешенных для одновременного выполнения на узле данных. | 16 |
dataNode.import.maxImportFileSizeInGB
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер файла (в ГБ) для файла импорта, где файл импорта относится либо к файлу на основе строк, либо к набору файлов на основе столбцов. | 16 |
dataNode.import.readBufferSizeInMB
| Описание | Значение по умолчанию |
|---|---|
| Размер блока данных (в МБ), считываемый из менеджера чанков узлом данных во время импорта. | 16 |
dataNode.import.maxTaskSlotNum
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество слотов, занимаемых каждой задачей импорта/преимпорта. | 16 |
dataNode.compaction.levelZeroBatchMemoryRatio
| Описание | Значение по умолчанию |
|---|---|
| Минимальный коэффициент свободной памяти для уплотнения нулевого уровня, выполняемого в пакетном режиме | 0.5 |
dataNode.compaction.levelZeroMaxBatchSize
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер партии означает максимальное количество сегментов L1/L2 в партии при выполнении уплотнения L0. По умолчанию -1, любое значение, меньшее 1, означает отсутствие ограничения. Допустимый диапазон: >= 1. | -1 |
dataNode.compaction.useMergeSort
| Описание | Значение по умолчанию |
|---|---|
| Включать ли режим mergeSort при выполнении mixCompaction. | false |
dataNode.compaction.maxSegmentMergeSort
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество сегментов, которые будут объединены в режиме mergeSort. | 30 |
dataNode.gracefulStopTimeout
| Описание | Значение по умолчанию |
|---|---|
| секунд. принудительная остановка узла без изящной остановки | 1800 |
dataNode.slot.slotCap
| Описание | Значение по умолчанию |
|---|---|
| Максимальное количество задач (например, уплотнение, импорт), разрешенных для одновременного выполнения на узле данных | 16 |
dataNode.clusteringCompaction.memoryBufferRatio
| Описание | Значение по умолчанию |
|---|---|
| Коэффициент буфера памяти для кластерного уплотнения. Данные, превышающие пороговое значение, будут выгружаться в хранилище. | 0.3 |
dataNode.clusteringCompaction.workPoolSize
| Описание | Значение по умолчанию |
|---|---|
| размер рабочего пула для одного задания по уплотнению кластеризации. | 8 |
dataNode.bloomFilterApplyParallelFactor
| Описание | Значение по умолчанию |
|---|---|
| коэффициент параллельности при применении pk к bloom-фильтру, по умолчанию 4*CPU_CORE_NUM | 4 |
dataNode.storage.deltalog
| Описание | Значение по умолчанию |
|---|---|
| формат дельталога, опции: [json, parquet]. | json |
dataNode.ip
| Описание | Значение по умолчанию |
|---|---|
| TCP/IP-адрес узла данных. Если не указан, используется первый одноадресный адрес. |
dataNode.port
| Описание | Значение по умолчанию |
|---|---|
| TCP-порт узла данных | 21124 |
dataNode.grpc.serverMaxSendSize
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер каждого RPC-запроса, который может отправить dataNode, единица измерения: байт | 536870912 |
dataNode.grpc.serverMaxRecvSize
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер каждого RPC-запроса, который может получить узел данных, единица измерения: байт | 268435456 |
dataNode.grpc.clientMaxSendSize
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер каждого RPC-запроса, который могут отправить клиенты на dataNode, единица измерения: байт | 268435456 |
dataNode.grpc.clientMaxRecvSize
| Описание | Значение по умолчанию |
|---|---|
| Максимальный размер каждого RPC-запроса, который могут получить клиенты на dataNode, единица измерения: байт | 536870912 |