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 |
---|---|
|
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 |
---|---|
|
-1 |
dataNode.channel.updateChannelCheckpointMaxParallel
Descrição | Valor por defeito |
---|---|
|
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.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.05 |
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.gracefulStopTimeout
Descrição | Valor predefinido |
---|---|
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 clustering. Os dados maiores do que o limite serão descarregados para o armazenamento. | 0.1 |
dataNode.clusteringCompaction.workPoolSize
Descrição | Valor por defeito |
---|---|
tamanho do pool de trabalhadores para um trabalho de compactação de clustering. | 8 |
dataNode.ip
Descrição | Valor por defeito |
---|---|
Endereço TCP/IP do dataNode. Se não for especificado, utilizar o primeiro endereço não transmissível |
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 |