Re: 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？

Thu, 27 Oct 2022 04:29:04 -0700 

Hi, LiTing

这是因为 flink-operator 默认配置中有以下两项默认值。

> taskmanager.numberOfTaskSlots: 2
> parallelism.default: 2

你可以在作业的 yaml 的 flinkConfiguration 中覆盖这两个默认配置


Best,
Weihua


On Thu, Oct 27, 2022 at 9:12 AM Jason_H <hyb_he...@163.com> wrote:

> hi，Liting Liu
>
> 看你的设置，是将并行度设置为了2，那么作业在运行的时候，所用到的slot为2个，你可以尝试修改并行度，来验证是否这个参数决定了你的taskslot的数量。
> 可以参考一下：
> https://blog.csdn.net/sinat_38079265/article/details/108535909
>
>
>
> | |
> Jason_H
> |
> |
> hyb_he...@163.com
> |
> ---- 回复的原邮件 ----
> | 发件人 | Liting Liu (litiliu)<liti...@cisco.com.INVALID> |
> | 发送日期 | 2022年10月26日 13:19 |
> | 收件人 | user-zh<user-zh@flink.apache.org> |
> | 主题 | 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ |
> hi:
> 我尝试使用flink-operator 1.2.0 用如下yaml 创建一个任务(该yaml
> 中并未设置taskmanager.numberOfTaskSlots).  遇到了一个问题。 可以稳定复现。
> ````
> apiVersion: flink.apache.org/v1beta1
> kind: FlinkDeployment
> metadata:
> name: basic-example
> spec:
> image: flink:1.15
> flinkVersion: v1_15
> flinkConfiguration:
> serviceAccount: flink
> jobManager:
> resource:
> memory: "2048m"
> cpu: 1
> taskManager:
> resource:
> memory: "2048m"
> cpu: 1
> job:
> jarURI: local:///opt/flink/examples/streaming/StateMachineExample.jar
> parallelism: 2
> upgradeMode: stateless
> ````
> 但是在生成的configMap （flink-config-basic-example）中，
> 发现“taskmanager.numberOfTaskSlots: 2”
> 不太理解，taskmanager.numberOfTaskSlots=2 是怎么被设置进去的（为什么是2？）。 感觉configMap
> 里不应该有这项配置才对，或者该配置项的值为1。
>
>
>
>
>

回复