当我们设置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相关推荐

  1. 【Flink】JobManager responsible for xx lost the leadership zk变动导致重启

    文章目录 1.概述 2.原因 2.1 内存相关 1.概述 Flink程序报错 org.apache.flink.util.FlinkException: JobManager responsible ...

  2. Flink实战问题(五):TaskManager memory configuration failed: Derived JVM Overhead size

    flink 运行任务突然报错,org.apache.flink.configuration.IllegalConfigurationException: TaskManager memory conf ...

  3. 【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 ...

  4. 【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 ...

  5. 【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 ...

  6. 【Flink】Metrics运作机制

    1.概述 转载并且补充:Flink源码剖析:Metrics运作机制 1. Metrics简介 1.1 什么是 Metrics? Flink 提供的 Metrics 可以在 Flink 内部收集一些指标 ...

  7. 【Flink】Flink 的 slotSharingGroup 有什么用

    1.概述 转载并且补充:Flink控制任务调度:作业链与处理槽共享组(slot-sharing-group) 为了实现并行执行,Flink应用会将算子划分为不同任务,然后将这些任务分配到集群中的不同进 ...

  8. 【Flink】Flink 源码之Buffer Debloating

    1.概述 转载:[Flink]Flink 源码之Buffer Debloating 2.什么是Buffer debloating Buffer Debloating是Flink 1.14新增的优化方式 ...

  9. 【Flink】FLink PipelineExecutorFactory 基于工厂模式的任务提交与SPI机制

    1.概述 转载: Flink1.10基于工厂模式的任务提交与SPI机制 Flink任务执行模式包含了yarn-session.standalone.per-job.local, 在1.10中又增加k8 ...

最新文章

  1. 彻底搞定用Xdoclet生成Hibernate所有配置文件
  2. java超时导致oracle锁表_java – 正确的设计,以避免Oracle死锁?
  3. html和css学习,HTML与CSS学习小结
  4. 创建一个多进程(multiprocessing.Process)
  5. linux读写二进制大文件
  6. 深度学习-Tensorflow2.2-RNN循环神经网络{11}-RNN空气污染预测-26
  7. 使用jenkins进行git多分支项目打包时的一个小问题
  8. 探讨浏览器CSS选择器的权重!!!
  9. iview中时间选择器可设置选择范围方法(一个月 一周等)
  10. 计算机专业哪家强,计算机专业哪家强?这4所大学水平一流,网友:都是“大佬”级别...
  11. 不用去验血,对照这张表,就能知道自己缺啥!千万收藏好!
  12. day7 java的构造器
  13. 易语言word模板复制粘贴_请给你的Word“打底妆”(让Word跑快些系列)
  14. JSON: jasckson 字段 过滤
  15. 5位数的数字黑洞是多少_奇妙的数字黑洞——6174
  16. oracle分区表和分区索引的概念
  17. 根据日期算星座 mysql,Hive 通过日期计算星座实例
  18. 微信输入法,终于来了。。。
  19. 风险加权资产(RWA)分析管理系统
  20. 计算机图形学实验二交互式绘制多边形

热门文章

  1. 02-感知机 读书笔记
  2. 花瓣搜索编辑网站的方法
  3. 【现代货币银行学】信用和利率(上)
  4. ps要点_故事要点-您做错了
  5. 验证(Verification)与确认(Validation)的区别
  6. Logstash 算术运算操作
  7. Android两个项目整合成一个
  8. 阵列天线的赋形波束综合(一)
  9. Linux中更新pycharm即删除旧的pycharm,装新的pycharm
  10. 基于精英反向学习和Lévy飞行的鲸鱼优化算法