Configurações relacionadas com o dataNode

dataNode.dataSync.flowGraph.maxQueueLength

Descrição	Valor por defeito
Comprimento máximo da fila de tarefas no fluxograma	16

dataNode.dataSync.flowGraph.maxParallelism

Descrição	Valor por defeito
Número máximo de tarefas executadas em paralelo no gráfico de fluxo	1024

dataNode.dataSync.maxParallelSyncMgrTasks

Descrição	Valor por defeito
O número máximo de tarefas de sincronização em simultâneo do mgr de sincronização do nó de dados a nível global	256

dataNode.dataSync.skipMode.enable

Descrição	Valor por defeito
Suporte para ignorar algumas mensagens de timetick para reduzir o uso da CPU	true

dataNode.dataSync.skipMode.skipNum

Descrição	Valor por defeito
Consome um por cada n registos ignorados	4

dataNode.dataSync.skipMode.coldTime

Descrição	Valor por defeito
Ativar o modo de salto depois de haver apenas mensagens de marcação de tempo durante x segundos	60

dataNode.segment.insertBufSize

Descrição

Valor por defeito

O tamanho máximo de cada ficheiro binlog num segmento armazenado em memória. Os ficheiros binlog cujo tamanho excede este valor são então descarregados para o serviço MinIO ou S3. Unidade: Byte Definir este parâmetro como demasiado pequeno faz com que o sistema armazene uma pequena quantidade de dados com demasiada frequência. Se o definir demasiado grande, aumenta a procura de memória por parte do sistema.

16777216

dataNode.segment.deleteBufBytes

Descrição	Valor por defeito
Tamanho máximo da memória intermédia em bytes para descarregar del para um único canal, predefinido como 16MB	16777216

dataNode.segment.syncPeriod

Descrição	Valor por defeito
O período para sincronizar segmentos se a memória intermédia não estiver vazia.	600

dataNode.memory.forceSyncEnable

Descrição	Valor por defeito
Definir verdadeiro para forçar a sincronização se a utilização da memória for demasiado elevada	verdadeiro

dataNode.memory.forceSyncSegmentNum

Descrição	Valor por defeito
número de segmentos a sincronizar, os segmentos com a maior memória intermédia superior serão sincronizados.	1

dataNode.memory.checkInterval

Descrição	Valor por defeito
o intervalo para verificar o uso de memória do datanode, em milissegundos	3000

dataNode.memory.forceSyncWatermark

Descrição	Valor por defeito
marca de água de memória para autónomo, ao atingir esta marca de água, os segmentos serão sincronizados.	0.5

dataNode.channel.workPoolSize

Descrição	Valor por defeito
especifica o tamanho do pool de trabalho global de todos os canais se este parâmetro <= 0, será definido como o número máximo de CPUs que podem estar a executar sugere-se que seja maior em grandes números de colecções para evitar bloqueios	-1

dataNode.channel.updateChannelCheckpointMaxParallel

Descrição	Valor por defeito
especifica o tamanho do work pool global para atualização do checkpoint do canal se este parâmetro <= 0, será definido como 10	10

dataNode.channel.updateChannelCheckpointInterval

Descrição	Valor por defeito
a duração do intervalo (em segundos) para o nó de dados atualizar o ponto de verificação do canal de cada canal	60

dataNode.channel.updateChannelCheckpointRPCTimeout

Descrição	Valor por defeito
tempo limite em segundos para a chamada RPC UpdateChannelCheckpoint	20

dataNode.channel.maxChannelCheckpointsPerPRC

Descrição	Valor por defeito
O número máximo de pontos de controlo do canal por RPC UpdateChannelCheckpoint.	128

dataNode.channel.channelCheckpointUpdateTickInSeconds

Descrição	Valor por defeito
A frequência, em segundos, com que o atualizador de pontos de controlo do canal executa actualizações.	10

dataNode.import.maxConcurrentTaskNum

Descrição	Valor por defeito
O número máximo de tarefas de importação/pré-importação que podem ser executadas simultaneamente em um nó de dados.	16

dataNode.import.maxImportFileSizeInGB

Descrição	Valor por defeito
O tamanho máximo do ficheiro (em GB) para um ficheiro de importação, em que um ficheiro de importação se refere a um ficheiro baseado em linhas ou a um conjunto de ficheiros baseados em colunas.	16

dataNode.import.readBufferSizeInMB

Descrição	Valor por defeito
O tamanho do bloco de dados (em MB) lido do gestor de blocos pelo nó de dados durante a importação.	16

dataNode.import.maxTaskSlotNum

Descrição	Valor por defeito
O número máximo de faixas horárias ocupadas por cada tarefa de importação/pré-importação.	16

dataNode.compaction.levelZeroBatchMemoryRatio

Descrição	Valor por defeito
O rácio mínimo de memória livre para a compactação de nível zero executada em modo batch	0.5

dataNode.compaction.levelZeroMaxBatchSize

Descrição	Valor por defeito
O tamanho máximo do lote refere-se ao número máximo de segmentos L1/L2 num lote durante a execução da compactação L0. A predefinição é -1, qualquer valor inferior a 1 significa que não há limite. Intervalo válido: >= 1.	-1

dataNode.compaction.useMergeSort

Descrição	Valor por defeito
Se deve ativar o modo mergeSort ao executar mixCompaction.	false

dataNode.compaction.maxSegmentMergeSort

Descrição	Valor por defeito
O número máximo de segmentos a serem fundidos no modo mergeSort.	30

dataNode.gracefulStopTimeout

Descrição	Valor por defeito
segundos. forçar paragem do nó sem paragem graciosa	1800

dataNode.slot.slotCap

Descrição	Valor por defeito
O número máximo de tarefas (por exemplo, compactação, importação) que podem ser executadas em simultâneo num nó de dados	16

dataNode.clusteringCompaction.memoryBufferRatio

Descrição	Valor por defeito
O rácio do buffer de memória da compactação de clusters. Os dados maiores do que o limite serão descarregados para o armazenamento.	0.3

dataNode.clusteringCompaction.workPoolSize

Descrição	Valor por defeito
Tamanho do pool de trabalhadores para um trabalho de compactação de clustering.	8

dataNode.bloomFilterApplyParallelFactor

Descrição	Valor por defeito
fator paralelo quando aplicar pk ao filtro bloom, predefinição para 4*CPU_CORE_NUM	4

dataNode.storage.deltalog

Descrição	Valor por defeito
formato deltalog, opções: [json, parquet]	json

dataNode.ip

Descrição	Valor por defeito
Endereço TCP/IP do dataNode. Se não for especificado, utilizar o primeiro endereço unicastable

dataNode.port

Descrição	Valor por defeito
Porta TCP do nó de dados	21124

dataNode.grpc.serverMaxSendSize

Descrição	Valor por defeito
O tamanho máximo de cada pedido RPC que o dataNode pode enviar, unidade: byte	536870912

dataNode.grpc.serverMaxRecvSize

Descrição	Valor por defeito
O tamanho máximo de cada pedido RPC que o dataNode pode receber, unidade: byte	268435456

dataNode.grpc.clientMaxSendSize

Descrição	Valor por defeito
O tamanho máximo de cada pedido RPC que os clientes no dataNode podem enviar, unidade: byte	268435456

dataNode.grpc.clientMaxRecvSize

Descrição	Valor por defeito
O tamanho máximo de cada pedido RPC que os clientes no dataNode podem receber, unidade: byte	536870912