Flink K8s操作员忽略taskmanager.host设置

t1rydlwq  于 2024-01-04  发布在  Apache
关注(0)|答案(1)|浏览(173)

我正在通过Flink K8s Operator使用FlinkDeployment资源中的这些设置部署作业:

spec:
flinkConfiguration:
taskmanager.host: 0.0.0.0 <-- ignored / not applied

字符串
当我在TM中查看flink-conf.yaml时,设置不存在。taskmanager.host被忽略的原因是什么?是bug还是什么?

fzsnzjdm

fzsnzjdm1#

可能是操作员通过服务发现自动发现它,这就是为什么没有必要手动指定它。
当你使用operator部署Flink时,它会为taskmanager创建一个headless服务,这是taskmanager发现彼此的一种方式。operator还将j obmanager.rpc.address配置设置为jobmanager的主机名,允许taskmanager连接到jobmanager。
在某些情况下,taskmanager.host仍会被使用,例如使用独立模式或自定义服务发现机制
如果需要设置taskmanager.host,您可以为任务管理器Pod设置TASK\_MANAGER\_HOST环境变量。
这个环境变量将覆盖操作员的默认行为,并强制任务管理器使用指定的主机。

相关问题