【Flink】JobManager memory configuration failed: Sum of configured JVM Metaspace (256.000mb
当我们设置jobmanager内存的时候,如果设置过小会出现如下问题(红色部分已标出)
提交参数如下
flink run -t yarn-per-job -D yarn.application.queue=test -Djobmanager.memory.process.size=100m -c com.test.Test /data/shan/flink-example-1.0-SNAPSHOT.jar
显示的日志如下
2022-03-28 16:58:32,875 INFO org.apache.flink.yarn.YarnClusterDescriptor [] - No path for the flink jar passed. Using the location of class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar
------------------------------------------------------------
The program finished with the following exception:org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: JobManager memory configuration failed: Sum of configured JVM Metaspace (256.000mb (268435456 bytes)) and JVM Overhead (192.000mb (201326592 bytes)) exceed configured Total Process Memory (100.000mb
【Flink】JobManager memory configuration failed: Sum of configured JVM Metaspace (256.000mb相关推荐
- 【Flink】JobManager responsible for xx lost the leadership zk变动导致重启
文章目录 1.概述 2.原因 2.1 内存相关 1.概述 Flink程序报错 org.apache.flink.util.FlinkException: JobManager responsible ...
- Flink实战问题(五):TaskManager memory configuration failed: Derived JVM Overhead size
flink 运行任务突然报错,org.apache.flink.configuration.IllegalConfigurationException: TaskManager memory conf ...
- 【Flink】报错 No pooled slot available and request to ResourceManager for new slot failed
文章目录 1.场景1 1.1 概述 1.2 问题 1.场景1 1.1 概述 改报错请参考:[Flink]Flink 1.9 升级 到 flink 1.12.4 报错 shaded netty4 Abs ...
- 【flink】Flink 1.12.2 源码浅析 : yarn-per-job模式解析 TaskMasger 启动
1.概述 转载:Flink 1.12.2 源码浅析 : yarn-per-job模式解析 [四] 上一篇: [flink]Flink 1.12.2 源码浅析 : yarn-per-job模式解析 Jo ...
- 【flink】Flink 1.12.2 源码浅析 : yarn-per-job模式解析 JobMasger启动 YarnJobClusterEntrypoint
1.概述 转载:Flink 1.12.2 源码浅析 : yarn-per-job模式解析 [三] 上一章:[flink]Flink 1.12.2 源码浅析 : yarn-per-job模式解析 yar ...
- 【Flink】Metrics运作机制
1.概述 转载并且补充:Flink源码剖析:Metrics运作机制 1. Metrics简介 1.1 什么是 Metrics? Flink 提供的 Metrics 可以在 Flink 内部收集一些指标 ...
- 【Flink】Flink 的 slotSharingGroup 有什么用
1.概述 转载并且补充:Flink控制任务调度:作业链与处理槽共享组(slot-sharing-group) 为了实现并行执行,Flink应用会将算子划分为不同任务,然后将这些任务分配到集群中的不同进 ...
- 【Flink】Flink 源码之Buffer Debloating
1.概述 转载:[Flink]Flink 源码之Buffer Debloating 2.什么是Buffer debloating Buffer Debloating是Flink 1.14新增的优化方式 ...
- 【Flink】FLink PipelineExecutorFactory 基于工厂模式的任务提交与SPI机制
1.概述 转载: Flink1.10基于工厂模式的任务提交与SPI机制 Flink任务执行模式包含了yarn-session.standalone.per-job.local, 在1.10中又增加k8 ...
最新文章
- 彻底搞定用Xdoclet生成Hibernate所有配置文件
- java超时导致oracle锁表_java – 正确的设计,以避免Oracle死锁?
- html和css学习,HTML与CSS学习小结
- 创建一个多进程(multiprocessing.Process)
- linux读写二进制大文件
- 深度学习-Tensorflow2.2-RNN循环神经网络{11}-RNN空气污染预测-26
- 使用jenkins进行git多分支项目打包时的一个小问题
- 探讨浏览器CSS选择器的权重!!!
- iview中时间选择器可设置选择范围方法(一个月 一周等)
- 计算机专业哪家强,计算机专业哪家强?这4所大学水平一流,网友:都是“大佬”级别...
- 不用去验血,对照这张表,就能知道自己缺啥!千万收藏好!
- day7 java的构造器
- 易语言word模板复制粘贴_请给你的Word“打底妆”(让Word跑快些系列)
- JSON: jasckson 字段 过滤
- 5位数的数字黑洞是多少_奇妙的数字黑洞——6174
- oracle分区表和分区索引的概念
- 根据日期算星座 mysql,Hive 通过日期计算星座实例
- 微信输入法,终于来了。。。
- 风险加权资产(RWA)分析管理系统
- 计算机图形学实验二交互式绘制多边形