开发者社区> 问答> 正文

flink 1.11 on k8s native session cluster模式报找不到conf

大佬们,请教个问题,我是在k8s上部署flink1.11 natvie session模式。

下载的flink-1.11.0-bin-scala_2.11.tgz

执行命令是

./bin/kubernetes-session.sh \

-Dkubernetes.cluster-id=k8s-session-1 \

-Dtaskmanager.memory.process.size=4096m \

-Dkubernetes.taskmanager.cpu=2 \

-Dtaskmanager.numberOfTaskSlots=4 \

-Dresourcemanager.taskmanager-timeout=3600000 \

-Dkubernetes.container.image=flink:1.11.0-scala_2.11

但是会报错,找不到configmap

[image: image.png]

我看是执行上述命令是会生成configmap的,为什么还会报找不到。

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 16:46:01 845 0
1 条回答
写回答
取消 提交回答
  • configmap "flink-config-k8s-session-1" not found的报错是正常的

    因为目前的实现是先创建JobManager Deployment,然后再创建ConfigMap并设置owner reference到deployment 所以你才会看到创建Pod的时候报ConfigMap还没有创建出来,这个是正常的信息,K8s会自动重试创建Pod

    你现在是任务起不来吗,还是有什么其他的问题?*来自志愿者整理的flink邮件归档

    2021-12-06 18:29:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 覃立辉 立即下载
Flink CDC Meetup PPT - 孙家宝 立即下载
Flink CDC Meetup PPT - 徐榜江 立即下载

相关镜像