问答 2024-04-11 来自:开发者社区

flink on yarn 运行,taskmanager 没有logs 是什么原因?

flink on yarn 运行,taskmanager 没有logs 是什么原因?

问答 2024-01-17 来自:开发者社区

flink on yarn模式,应用模式,一个TaskManager至少会占用2G内存吗?

环境说明:flink 1.15CDH集群6.3.2现在采用flink on yarn模式,应用模式向yarn提交作业时,指定-Dtaskmanager.memory.process.size参数来设置TaskManager的内存,发现不管这个参数设多小,在yarn的界面上看这个TaskManager对应的Container占用的内存最小都会占用2G内存,请问这是为什么?

问答 2022-08-03 来自:开发者社区

flink以yarn pre模式提交job,那么taskmanager执行在哪一台节点上,就是消耗该

flink以yarn pre模式提交job,那么taskmanager执行在哪一台节点上,就是消耗该台节点的内存资源和CPU 是吗?

问答 2021-12-30 来自:开发者社区

flink的yarn session模式怎么预起多个taskmanager?

flink on yarn的yarn session模式怎么让他预启动多个taskmanger,这样方便将1个作业的多个并发分配到多个taskmanager上,而不是默认的先把1个taskmanger分配完再分配第2个taskmanger了

问答 2021-12-30 来自:开发者社区

flink的yarn session模式怎么把提交给他的作业均匀分配给所有的taskmanager

flink部署yarn session模式,发现提交给他的作业每次都是先将1个taskmanager上的slot全都分配完后再起1个taskmanger,这导致给1个作业配置的所有并发全都在1个taskmanger上反压很高。有没有办法让这种yarn session模式对每个作业的并发分配到不同taskmanger上啊?

问答 2019-04-23 来自:开发者社区

Flink on Yarn启动的TaskManager只有一个

Flink On Yarn 模式,单个任务提交的时候,任务提交成功了,但是我的TaskManager只启动了一个,其他的TaskManager都没启动起来,当然资源也没法用,这是为什么啊???我的启动命令是这样的:flink -m yarn-cluster -yn 3 sse.jar命名要启动三个TaskManager,但是只启动了一个,我的配置如下: fs.hdfs.hadoopconf: /....

问答 2019-01-10 来自:开发者社区

flink on yarn 如果某个taskmanager出现故障,程序失败后,恢复流程是怎样的

flink on yarn 如果某个taskmanager出现故障,程序失败后,恢复流程是怎样的

问答 2018-10-25 来自:开发者社区

Flink on Yarn:一个yarn的Nodemanager上可能会有多个TaskManager吗

咨询下,Flink on Yarn中。Flink的taskmanager是在yarn的container中启动的,而一个yarn的Nodemanager节点可能有多个contanier。问题就是:flink集群的多个taskmager有没有可能是在同一个Nodemanager的多个container里面启动的? 还是说必须是在不同的Nodemanager上的container上启动的?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注