Konfigurasi terkait dataNode
dataNode.dataSync.flowGraph.maxQueueLength
| Deskripsi | Nilai Default |
|---|---|
| Panjang maksimum antrean tugas dalam diagram alir | 16 |
dataNode.dataSync.flowGraph.maxParallelism
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum tugas yang dieksekusi secara paralel dalam diagram alir | 1024 |
dataNode.dataSync.maxParallelSyncMgrTasks
| Deskripsi | Nilai Default |
|---|---|
| Jumlah tugas sinkronisasi serentak maksimum dari mgr sinkronisasi datanode secara global | 256 |
dataNode.dataSync.skipMode.enable
| Deskripsi | Nilai Default |
|---|---|
| Mendukung melewatkan beberapa pesan tanda waktu untuk mengurangi penggunaan CPU | benar |
dataNode.dataSync.skipMode.skipNum
| Deskripsi | Nilai Default |
|---|---|
| Konsumsi satu untuk setiap n catatan yang dilewati | 4 |
dataNode.dataSync.skipMode.coldTime
| Deskripsi | Nilai Default |
|---|---|
| Aktifkan mode lewati setelah hanya ada msg tanda waktu selama x detik | 60 |
dataNode.segment.insertBufSize
| Deskripsi | Nilai Default |
|---|---|
|
|
16777216 |
dataNode.segment.deleteBufBytes
| Deskripsi | Nilai Default |
|---|---|
| Ukuran buffer maksimum dalam byte untuk melakukan flush del untuk satu saluran, defaultnya adalah 16MB | 16777216 |
dataNode.segment.syncPeriod
| Deskripsi | Nilai Default |
|---|---|
| Periode untuk menyinkronkan segmen jika buffer tidak kosong. | 600 |
dataNode.memory.forceSyncEnable
| Deskripsi | Nilai Default |
|---|---|
| Tetapkan true untuk memaksa sinkronisasi jika penggunaan memori terlalu tinggi | true |
dataNode.memory.forceSyncSegmentNum
| Deskripsi | Nilai Default |
|---|---|
| jumlah segmen yang akan disinkronkan, segmen dengan buffer terbesar akan disinkronkan. | 1 |
dataNode.memory.checkInterval
| Deskripsi | Nilai Default |
|---|---|
| interal untuk memeriksa penggunaan memori datanode, dalam milidetik | 3000 |
dataNode.memory.forceSyncWatermark
| Deskripsi | Nilai Default |
|---|---|
| tanda air memori untuk mandiri, setelah mencapai tanda air ini, segmen akan disinkronkan. | 0.5 |
dataNode.channel.workPoolSize
| Deskripsi | Nilai Default |
|---|---|
|
|
-1 |
dataNode.channel.updateChannelCheckpointMaxParallel
| Deskripsi | Nilai Default |
|---|---|
|
|
10 |
dataNode.channel.updateChannelCheckpointInterval
| Deskripsi | Nilai Default |
|---|---|
| durasi interval (dalam detik) untuk datanode untuk memperbarui pos pemeriksaan saluran dari setiap saluran | 60 |
dataNode.channel.updateChannelCheckpointRPCTimeout
| Deskripsi | Nilai Default |
|---|---|
| batas waktu dalam detik untuk panggilan RPC UpdateChannelCheckpoint | 20 |
dataNode.channel.maxChannelCheckpointsPerPRC
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum titik pemeriksaan saluran per RPC UpdateChannelCheckpoint. | 128 |
dataNode.channel.channelCheckpointUpdateTickInSeconds
| Deskripsi | Nilai Default |
|---|---|
| Frekuensi, dalam detik, di mana pemutakhiran pos pemeriksaan saluran mengeksekusi pembaruan. | 10 |
dataNode.import.maxConcurrentTaskNum
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum tugas impor/pra-impor yang diizinkan untuk dijalankan secara bersamaan pada datanode. | 16 |
dataNode.import.maxImportFileSizeInGB
| Deskripsi | Nilai Default |
|---|---|
| Ukuran file maksimum (dalam GB) untuk file impor, di mana file impor mengacu pada file Berbasis Baris atau sekumpulan file Berbasis Kolom. | 16 |
dataNode.import.readBufferSizeInMB
| Deskripsi | Nilai Default |
|---|---|
| Ukuran blok data (dalam MB) yang dibaca dari manajer chunk oleh datanode selama impor. | 16 |
dataNode.import.maxTaskSlotNum
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum slot yang ditempati oleh setiap tugas impor/pra-impor. | 16 |
dataNode.compaction.levelZeroBatchMemoryRatio
| Deskripsi | Nilai Default |
|---|---|
| Rasio memori minimal dari memori bebas untuk pemadatan level nol yang dijalankan dalam mode batch | 0.5 |
dataNode.compaction.levelZeroMaxBatchSize
| Deskripsi | Nilai Default |
|---|---|
| Ukuran batch maksimum mengacu pada jumlah maksimum segmen L1/L2 dalam batch saat menjalankan pemadatan L0. Default ke -1, nilai apa pun yang kurang dari 1 berarti tidak ada batas. Rentang yang valid: >= 1. | -1 |
dataNode.compaction.useMergeSort
| Deskripsi | Nilai Default |
|---|---|
| Apakah akan mengaktifkan mode penggabunganSortir saat melakukan pemadatan campuran. | false |
dataNode.compaction.maxSegmentMergeSort
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum segmen yang akan digabungkan dalam mode mergeSort. | 30 |
dataNode.gracefulStopTimeout
| Deskripsi | Nilai Default |
|---|---|
| detik. paksa berhenti simpul tanpa berhenti dengan lembut | 1800 |
dataNode.slot.slotCap
| Deskripsi | Nilai Default |
|---|---|
| Jumlah maksimum tugas (mis. pemadatan, pengimporan) yang diizinkan untuk berjalan secara bersamaan pada sebuah datanode | 16 |
dataNode.clusteringCompaction.memoryBufferRatio
| Deskripsi | Nilai Default |
|---|---|
| Rasio buffer memori untuk pemadatan pengelompokan. Data yang lebih besar dari ambang batas akan dibuang ke penyimpanan. | 0.3 |
dataNode.clusteringCompaction.workPoolSize
| Deskripsi | Nilai Default |
|---|---|
| ukuran kumpulan pekerja untuk satu pekerjaan pemadatan pengelompokan. | 8 |
dataNode.bloomFilterApplyParallelFactor
| Deskripsi | Nilai Default |
|---|---|
| faktor paralel saat menerapkan pk ke filter bloom, default ke 4*CPU_CORE_NUM | 4 |
dataNode.storage.deltalog
| Deskripsi | Nilai Default |
|---|---|
| format deltalog, opsi: [json, parket] | json |
dataNode.ip
| Deskripsi | Nilai Default |
|---|---|
| Alamat TCP/IP dari dataNode. Jika tidak ditentukan, gunakan alamat pertama yang dapat di-unicast |
dataNode.port
| Deskripsi | Nilai Default |
|---|---|
| Port TCP dari dataNode | 21124 |
dataNode.grpc.serverMaxSendSize
| Deskripsi | Nilai Default |
|---|---|
| Ukuran maksimum setiap permintaan RPC yang dapat dikirim oleh dataNode, satuan: byte | 536870912 |
dataNode.grpc.serverMaxRecvSize
| Deskripsi | Nilai Default |
|---|---|
| Ukuran maksimum setiap permintaan RPC yang dapat diterima oleh dataNode, satuan: byte | 268435456 |
dataNode.grpc.clientMaxSendSize
| Deskripsi | Nilai Default |
|---|---|
| Ukuran maksimum setiap permintaan RPC yang dapat dikirim oleh klien pada dataNode, satuan: byte | 268435456 |
dataNode.grpc.clientMaxRecvSize
| Deskripsi | Nilai Default |
|---|---|
| Ukuran maksimum setiap permintaan RPC yang dapat diterima oleh klien di dataNode, satuan: byte | 536870912 |