开发者社区> 问答> 正文

flink1.11 set yarn slots failed

使用如下命令,设置Number of slots per TaskManager /opt/flink-1.11.0/bin/flink run-application -t yarn-application
-Djobmanager.memory.process.size=1024m
-Dtaskmanager.memory.process.size=2048m
-ys 4 \

发现并不能override/opt/flink-1.11.0/bin/flink/conf/flink-conf.yaml中的默认值,每次要调整只能通过更改flink-conf.yaml的方式才能生效,请问使用run-application的方式,怎样设置Number of slots per TaskManager? 另外,有哪些方式可以增Flink UI中的大Available Task Slots的值,现在每次提交作业都是0*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-07 15:24:13 767 0
1 条回答
写回答
取消 提交回答
  • -t是新引入的参数,是不支持以前的-yxxx参数的

    你需要使用-Dtaskmanager.numberOfTaskSlots=4这样来设置

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

    2021-12-07 15:52:18
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载