在 Flink 中，如果您的任务在 YARN 上运行，您可以通过以下方式来调整任务的资源分配：
在 flink-conf.yaml 文件中设置默认的 JobManager 和 TaskManager 内存和 CPU：
stylus
Copy

JobManager 内存和 CPU

jobmanager.memory.process.size: 1024m
jobmanager.cpu.cores: 1

TaskManager 内存和 CPU

taskmanager.memory.process.size: 2048m
taskmanager.cpu.cores: 2
以上配置将默认为 JobManager 分配 1GB 的内存和 1 个 CPU 核心，为 TaskManager 分配 2GB 的内存和 2 个 CPU 核心。如果您的任务需要更多的资源，可以相应地增加这些值。
在提交任务时，通过 –jobmanager.memory.process.size、–jobmanager.cpu.cores、–taskmanager.memory.process.size 和 –taskmanager.cpu.cores 参数来调整 JobManager 和 TaskManager 的资源分配：
stylus
Copy
./bin/flink run –jobmanager.memory.process.size 2048m
–jobmanager.cpu.cores 2
–taskmanager.memory.process.size 4096m
–taskmanager.cpu.cores 4
/path/to/your/job.jar
以上命令将为 JobManager 分配 2GB 的内存和 2 个 CPU 核心，为 TaskManager 分配 4GB 的内存和 4 个 CPU 核心。如果您的任务需要更多的资源，可以相应地增加这些值。