Configuraciones relacionadas con dataNode
dataNode.dataSync.flowGraph.maxQueueLength
Descripción | Valor por defecto |
---|---|
Longitud máxima de la cola de tareas en el diagrama de flujo | 16 |
dataNode.dataSync.flowGraph.maxParallelism
Descripción | Valor por defecto |
---|---|
Número máximo de tareas ejecutadas en paralelo en el diagrama de flujo | 1024 |
dataNode.dataSync.maxParallelSyncMgrTasks
Descripción | Valor por defecto |
---|---|
Número máximo de tareas de sincronización concurrentes de datanode sync mgr globalmente | 256 |
dataNode.dataSync.skipMode.enable
Descripción | Valor por defecto |
---|---|
Soporta omitir algunos mensajes timetick para reducir el uso de CPU | true |
dataNode.dataSync.skipMode.skipNum
Descripción | Valor por defecto |
---|---|
Consume uno por cada n registros omitidos | 4 |
dataNode.dataSync.skipMode.coldTime
Descripción | Valor por defecto |
---|---|
Activa el modo omitir después de que sólo haya msg de timetick durante x segundos | 60 |
dataNode.segment.insertBufSize
Descripción | Valor por defecto |
---|---|
|
16777216 |
dataNode.segment.deleteBufBytes
Descripción | Valor por defecto |
---|---|
Tamaño máximo del buffer en bytes a flush del para un solo canal, por defecto 16MB | 16777216 |
dataNode.segment.syncPeriod
Descripción | Valor por defecto |
---|---|
El periodo para sincronizar segmentos si el buffer no está vacío. | 600 |
dataNode.memory.forceSyncEnable
Descripción | Valor por defecto |
---|---|
Establece true para forzar la sincronización si el uso de memoria es demasiado alto | verdadero |
dataNode.memory.forceSyncSegmentNum
Descripción | Valor por defecto |
---|---|
número de segmentos a sincronizar, se sincronizarán los segmentos con el buffer más grande. | 1 |
dataNode.memory.checkInterval
Descripción | Valor por defecto |
---|---|
el intervalo para comprobar el uso de memoria del datanode, en milisegundos | 3000 |
dataNode.memory.forceSyncWatermark
Descripción | Valor por defecto |
---|---|
marca de agua de memoria para standalone, al alcanzar esta marca de agua, los segmentos serán sincronizados. | 0.5 |
dataNode.channel.workPoolSize
Descripción | Valor por defecto |
---|---|
|
-1 |
dataNode.channel.updateChannelCheckpointMaxParallel
Descripción | Valor por defecto |
---|---|
|
10 |
dataNode.channel.updateChannelCheckpointInterval
Descripción | Valor por defecto |
---|---|
la duración del intervalo (en segundos) para que el datanode actualice el punto de control de cada canal | 60 |
dataNode.channel.updateChannelCheckpointRPCTimeout
Descripción | Valor por defecto |
---|---|
tiempo de espera en segundos para la llamada RPC UpdateChannelCheckpoint | 20 |
dataNode.channel.maxChannelCheckpointsPerPRC
Descripción | Valor por defecto |
---|---|
El número máximo de puntos de control del canal por UpdateChannelCheckpoint RPC. | 128 |
dataNode.channel.channelCheckpointUpdateTickInSeconds
Descripción | Valor por defecto |
---|---|
La frecuencia, en segundos, con la que el actualizador de puntos de control del canal ejecuta las actualizaciones. | 10 |
dataNode.import.maxConcurrentTaskNum
Descripción | Valor por defecto |
---|---|
Número máximo de tareas de importación/preimportación que pueden ejecutarse simultáneamente en un nodo de datos. | 16 |
dataNode.import.maxImportFileSizeInGB
Descripción | Valor por defecto |
---|---|
El tamaño máximo de archivo (en GB) para un archivo de importación, donde un archivo de importación se refiere a un archivo basado en filas o a un conjunto de archivos basados en columnas. | 16 |
dataNode.import.readBufferSizeInMB
Descripción | Valor por defecto |
---|---|
El tamaño del bloque de datos (en MB) leído del gestor de trozos por el datanode durante la importación. | 16 |
dataNode.compaction.levelZeroBatchMemoryRatio
Descripción | Valor por defecto |
---|---|
La proporción mínima de memoria libre para la compactación de nivel cero que se ejecuta en modo por lotes | 0.05 |
dataNode.compaction.levelZeroMaxBatchSize
Descripción | Valor por defecto |
---|---|
Tamaño máximo de lote se refiere al número máximo de segmentos L1/L2 en un lote cuando se ejecuta la compactación L0. Por defecto -1, cualquier valor inferior a 1 significa que no hay límite. Rango válido: >= 1. | -1 |
dataNode.gracefulStopTimeout
Descripción | Valor por defecto |
---|---|
segundos. forzar parada nodo sin graceful stop | 1800 |
dataNode.slot.slotCap
Descripción | Valor por defecto |
---|---|
Número máximo de tareas (por ejemplo, compactación, importación) que se pueden ejecutar simultáneamente en un nodo de datos. | 16 |
dataNode.clusteringCompaction.memoryBufferRatio
Descripción | Valor por defecto |
---|---|
Proporción del búfer de memoria de la compactación en clúster. Los datos mayores que el umbral se enviarán al almacenamiento. | 0.1 |
dataNode.clusteringCompaction.workPoolSize
Descripción | Valor por defecto |
---|---|
Tamaño del grupo de trabajadores para un trabajo de compactación en clúster. | 8 |
dataNode.ip
Descripción | Valor por defecto |
---|---|
Dirección TCP/IP de dataNode. Si no se especifica, utiliza la primera dirección unicastable |
dataNode.port
Descripción | Valor por defecto |
---|---|
Puerto TCP de dataNode | 21124 |
dataNode.grpc.serverMaxSendSize
Descripción | Valor por defecto |
---|---|
El tamaño máximo de cada petición RPC que el dataNode puede enviar, unidad: byte | 536870912 |
dataNode.grpc.serverMaxRecvSize
Descripción | Valor por defecto |
---|---|
El tamaño máximo de cada petición RPC que el dataNode puede recibir, unidad: byte | 268435456 |
dataNode.grpc.clientMaxSendSize
Descripción | Valor por defecto |
---|---|
El tamaño máximo de cada petición RPC que los clientes del dataNode pueden enviar, unidad: byte | 268435456 |
dataNode.grpc.clientMaxRecvSize
Descripción | Valor por defecto |
---|---|
El tamaño máximo de cada petición RPC que los clientes en dataNode pueden recibir, unidad: byte | 536870912 |