dataNode-bezogene Konfigurationen
dataNode.dataSync.flowGraph.maxQueueLength
| Beschreibung | Standardwert |
|---|---|
| Maximale Länge der Aufgabenwarteschlange im Flussdiagramm | 16 |
dataNode.dataSync.flowGraph.maxParallelism
| Beschreibung | Standardwert |
|---|---|
| Maximale Anzahl der parallel ausgeführten Aufgaben im Flussdiagramm | 1024 |
dataNode.dataSync.maxParallelSyncMgrTasks
| Beschreibung | Standardwert |
|---|---|
| Maximale Anzahl gleichzeitiger Sync-Aufgaben von Datanode sync mgr global | 256 |
dataNode.dataSync.skipMode.enable
| Beschreibung | Standardwert |
|---|---|
| Unterstützt das Überspringen einiger Timetick-Meldungen, um die CPU-Auslastung zu reduzieren | true |
dataNode.dataSync.skipMode.skipNum
| Beschreibung | Standardwert |
|---|---|
| Verbraucht eine für jeweils n übersprungene Datensätze | 4 |
dataNode.dataSync.skipMode.coldTime
| Beschreibung | Standardwert |
|---|---|
| Schaltet den Überspringungsmodus ein, wenn es für x Sekunden nur Zeittick-Meldungen gibt | 60 |
dataNode.segment.insertBufSize
| Beschreibung | Standardwert |
|---|---|
|
|
16777216 |
dataNode.segment.deleteBufBytes
| Beschreibung | Standardwert |
|---|---|
| Maximale Puffergröße in Bytes für einen einzelnen Kanal, Standardwert: 16 MB | 16777216 |
dataNode.segment.syncPeriod
| Beschreibung | Standardwert |
|---|---|
| Der Zeitraum für die Synchronisierung von Segmenten, wenn der Puffer nicht leer ist. | 600 |
dataNode.memory.forceSyncEnable
| Beschreibung | Voreinstellung Wert |
|---|---|
| Setzen Sie true, um die Synchronisierung zu erzwingen, wenn der Speicherverbrauch zu hoch ist | wahr |
dataNode.memory.forceSyncSegmentNum
| Beschreibung | Standardwert |
|---|---|
| Anzahl der zu synchronisierenden Segmente; die Segmente mit dem größten Puffer werden synchronisiert. | 1 |
dataNode.memory.checkInterval
| Beschreibung | Standardwert |
|---|---|
| Intervall für die Überprüfung der Datanode-Speicherauslastung, in Millisekunden | 3000 |
dataNode.memory.forceSyncWatermark
| Beschreibung | Standardwert |
|---|---|
| Speicher-Wasserzeichen für Standalone, bei Erreichen dieses Wasserzeichens werden die Segmente synchronisiert. | 0.5 |
dataNode.channel.workPoolSize
| Beschreibung | Standardwert |
|---|---|
|
|
-1 |
dataNode.channel.updateChannelCheckpointMaxParallel
| Beschreibung | Standardwert |
|---|---|
|
|
10 |
dataNode.channel.updateChannelCheckpointInterval
| Beschreibung | Standardwert |
|---|---|
| Dauer des Intervalls (in Sekunden), in dem der Datenknoten die Kanalprüfpunkte der einzelnen Kanäle aktualisiert | 60 |
dataNode.channel.updateChannelCheckpointRPCTimeout
| Beschreibung | Standardwert |
|---|---|
| Timeout in Sekunden für UpdateChannelCheckpoint RPC-Aufruf | 20 |
dataNode.channel.maxChannelCheckpointsPerPRC
| Beschreibung | Standardwert |
|---|---|
| Die maximale Anzahl von Kanalprüfpunkten pro UpdateChannelCheckpoint RPC. | 128 |
dataNode.channel.channelCheckpointUpdateTickInSeconds
| Beschreibung | Standardwert |
|---|---|
| Die Häufigkeit, mit der der Channel Checkpoint Updater Aktualisierungen durchführt, in Sekunden. | 10 |
dataNode.import.maxConcurrentTaskNum
| Beschreibung | Standardwert |
|---|---|
| Die maximale Anzahl von Import-/Pre-Import-Aufgaben, die gleichzeitig auf einem Datenknoten ausgeführt werden können. | 16 |
dataNode.import.maxImportFileSizeInGB
| Beschreibung | Standardwert |
|---|---|
| Die maximale Dateigröße (in GB) für eine Importdatei, wobei sich eine Importdatei entweder auf eine zeilenbasierte Datei oder einen Satz von spaltenbasierten Dateien bezieht. | 16 |
dataNode.import.readBufferSizeInMB
| Beschreibung | Standardwert |
|---|---|
| Die Datenblockgröße (in MB), die der Datenknoten während des Imports aus dem Chunk-Manager liest. | 16 |
dataNode.compaction.levelZeroBatchMemoryRatio
| Beschreibung | Voreinstellung Wert |
|---|---|
| Das minimale Speicherverhältnis des freien Speichers für die Verdichtung der Ebene Null, die im Batch-Modus ausgeführt wird | 0.05 |
dataNode.compaction.levelZeroMaxBatchSize
| Beschreibung | Standardwert |
|---|---|
| Maximale Stapelgröße bezieht sich auf die maximale Anzahl von L1/L2-Segmenten in einem Stapel bei der Ausführung der L0-Kompaktierung. Standardwert ist -1, jeder Wert kleiner als 1 bedeutet keine Begrenzung. Gültiger Bereich: >= 1. | -1 |
dataNode.gracefulStopTimeout
| Beschreibung | Standardwert |
|---|---|
| Sekunden. erzwingt das Anhalten des Knotens ohne ordnungsgemäßes Anhalten | 1800 |
dataNode.slot.slotCap
| Beschreibung | Standardwert |
|---|---|
| Die maximale Anzahl von Aufgaben (z. B. Verdichtung, Import), die gleichzeitig auf einem Datenknoten ausgeführt werden dürfen | 16 |
dataNode.clusteringCompaction.memoryBufferRatio
| Beschreibung | Standardwert |
|---|---|
| Das Verhältnis des Speicherpuffers der Clusterverdichtung. Daten, die größer als der Schwellenwert sind, werden in den Speicher gespült. | 0.1 |
dataNode.clusteringCompaction.workPoolSize
| Beschreibung | Standardwert |
|---|---|
| Größe des Worker-Pools für einen Clustering-Verdichtungsauftrag. | 8 |
dataNode.ip
| Beschreibung | Standardwert |
|---|---|
| TCP/IP-Adresse von dataNode. Wenn nicht angegeben, wird die erste unicastbare Adresse verwendet. |
dataNode.port
| Beschreibung | Standardwert |
|---|---|
| TCP-Port von dataNode | 21124 |
dataNode.grpc.serverMaxSendSize
| Beschreibung | Standardwert |
|---|---|
| Die maximale Größe jeder RPC-Anfrage, die der dataNode senden kann, Einheit: Byte | 536870912 |
dataNode.grpc.serverMaxRecvSize
| Beschreibung | Standardwert |
|---|---|
| Die maximale Größe jeder RPC-Anfrage, die der dataNode empfangen kann, Einheit: Byte | 268435456 |
dataNode.grpc.clientMaxSendSize
| Beschreibung | Standardwert |
|---|---|
| Die maximale Größe jeder RPC-Anfrage, die die Clients auf dataNode senden können, Einheit: Byte | 268435456 |
dataNode.grpc.clientMaxRecvSize
| Beschreibung | Standardwert |
|---|---|
| Die maximale Größe jeder RPC-Anfrage, die die Clients auf dataNode empfangen können, Einheit: Byte | 536870912 |