我正在通过Flink K8s Operator使用FlinkDeployment资源中的这些设置部署作业:
spec:
flinkConfiguration:
taskmanager.host: 0.0.0.0 <-- ignored / not applied
字符串
当我在TM中查看flink-conf.yaml
时,设置不存在。taskmanager.host
被忽略的原因是什么?是bug还是什么?
我正在通过Flink K8s Operator使用FlinkDeployment资源中的这些设置部署作业:
spec:
flinkConfiguration:
taskmanager.host: 0.0.0.0 <-- ignored / not applied
字符串
当我在TM中查看flink-conf.yaml
时,设置不存在。taskmanager.host
被忽略的原因是什么?是bug还是什么?
1条答案
按热度按时间fzsnzjdm1#
可能是操作员通过服务发现自动发现它,这就是为什么没有必要手动指定它。
当你使用operator部署Flink时,它会为taskmanager创建一个headless服务,这是taskmanager发现彼此的一种方式。operator还将j
obmanager.rpc.address
配置设置为jobmanager的主机名,允许taskmanager连接到jobmanager。在某些情况下,
taskmanager.host
仍会被使用,例如使用独立模式或自定义服务发现机制如果需要设置
taskmanager.host
,您可以为任务管理器Pod设置TASK\_MANAGER\_HOST
环境变量。这个环境变量将覆盖操作员的默认行为,并强制任务管理器使用指定的主机。