---
title: 参数配置
description: "本实例列举了某Flink调优场景中的部分参数配置，仅供参考。"
url: https://www.hikunpeng.com/document/detail/zh/kunpengbds/ecosystemEnable/Flink/kunpengflinkhdp_05_0021.html
sourcePath: /source/zh/kunpengbds/ecosystemEnable/Flink/kunpengflinkhdp_05_0021.html
indexId: 6d1f42b37b7a531be48c097457b51062b0eb48efbdf07e5d37b3926c3648ab8172
---
# 参数配置

本实例列举了某Flink调优场景中的部分参数配置，仅供参考。

#### Web配置

| 组件 | 参数名 | 推荐值 | 修改原因 |
| --- | --- | --- | --- |
| Kafka\->Broker | log.dir | /hadoop/data1/kafka\-logs, /hadoop/data2/kafka\-logs, /hadoop/data3/kafka\-logs, ... /hadoop/data11/kafka\-logs, /hadoop/data12/kafka\-logs | 配置Kafka使用盘的数量为12盘，防止硬盘读写成为瓶颈。 |
| Kafka\->Broker | num.partitions | 36 | 使用更多的partition数量，配合log.dir参数提升Kafka性能。以及对应Flink数据生成器的并发度。 |
| Kafka\->Broker | num.network.threads | 128 | 增大Kafka网络线程数。 |
| Kafka\->Broker | num.io.threads | 8 | Flink数据量不大，保持IO线程数较小，减轻CPU压力。 |
| Yarn\->Nodemanager | yarn.nodemanager.resource.memory\-mb | 224256 | 增大Yarn每个nodemanager能分配的最大内存数。 |
| Yarn\->Nodemanager | yarn.nodemanager.resource. cpu\-vcores | 48 | 增大Yarn每个nodemanager能分配的最大vcores数。 |
| Yarn\->Nodemanager | yarn.nodemanager.numa\-awareness.enabled | true | Yarn NUMA绑核开关开启。 |
| Yarn\->Nodemanager | yarn.nodemanager.numa\-awareness.read\-topology | true | 选择由参数进行绑核还是启动命令中进行绑核，Flink选择启动命令中绑核。 |
| Yarn\->Nodemanager | yarn.nodemanager.numa\-awareness.numactl.cmd | /usr/bin/numactl | NUMA绑核工具系统路径。 |


Kafka参数配置路径：


Yarn参数配置路径：


#### 客户端配置

仅列出需要修改的调优参数。


Flink任务提交配置。

```
yarn-session.sh -s 16 -jm 5000 -tm 30000 -d
slot: 7 (x86为16)
jobmanager.memory: 5000
taskmanager.memory: 30000
```

yahoo_benchmark_streaming用例配置（修改stream-bench-hdp.sh）。

```
Partitions: 36
Load: 8600000    (x86为6400000)
TEST_TIME: 240
```