问答 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内存,请问这是为什么?

问答 2023-02-06 来自:开发者社区

生产环境 部署flinksql 任务( flink on yarn )太消耗slot.怎么办?

想请教下生产环境 部署flinksql 任务( flink on yarn )太消耗slot.这个要怎么解决. 是把slot 和cpu之比调大吗? 具体比例多少合适啊?

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

Flink On Yarn部署模式下,提交Flink作业 是否可以不打fat jar

目前遇到的问题是由于存在依赖冲突的问题,项目中不能打fatjar,所以想咨询一下在Flink On Yarn部署模式下,提交Flink作业如何加载第三方依赖包。

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

Flink中的Flink on Yarn的两种运行方式具体是些什么啊?

Flink中的Flink on Yarn的两种运行方式具体是些什么啊?

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

Flink中的Flink on Yarn具体是指什么啊?

Flink中的Flink on Yarn具体是指什么啊?

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

flink on yarn。

我使用的事flink on yarn。在执行命令时:   flink run -m yarn-cluster ./examples/batch/WordCount.jar   结果却报错了:  The program finished with the following exception: org.apache.flink.client.program....

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

Flink Sql client on yarn 问题

你好。我在sql client 配置的yarn yarn日志报错如下 2020-10-09 14:17:37,721 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - ----------------------------------------------------------------------------....

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

flink on yarn容器异常退出

如题,求解决*来自志愿者整理的flink

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

flink 1.11.2 on yarn 可用slot始终为0,job无法提交如何处理?

http://apache-flink.147419.n8.nabble.com/file/t1162/Screenshot_2020-12-09_153858.png 启动命令: ./bin/flink run-application -t yarn-application -Djobmanager.memory.process.size=2048m -Dtaskmanager.memory.....

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

flink on yarn jdk版本问题

我们使用了TDH中的yarn(hadoop2.7,jdk1.7),原先使用spark的时候,也遇到过jdk版本最低1.8的情况,我们是通过如下方式解决的(考虑到现场公用TDH集群不能更改): spark-submit中可以通过添加参数 --conf "spark.yarn.appMasterEnv.JAVA_HOME=/usr/java/jdk1.8.0_25/" --conf "spark......

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

产品推荐

阿里云实时计算Flink

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

+关注