求助，Flink CDC 之前yarn session 上了二十多个SQL任务。一次新提交一个任务？
求助，Flink CDC 之前yarn session 上了二十多个SQL任务。一次新提交一个任务，估计是AM资源紧张，一直在提交尝试中。后来就出事故了，网络带宽占满，被数据中心人员找了过来。一看YARN SESSION中的所有的JOB都在initing 中，把任务停掉就降下来了。这种情况帮忙分析一下，是怎么产生的，要如何才能避免呢？动不动就占满带宽影响太大了。所有的CDC表都是latest 启动模式，不涉及到snapshot，按理说不应该有那么大网络IO？
展开
收起
问答分类：
相关产品：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
热门讨论
热门文章
FFA 2024 大会门票免费送！AI时代下大数据技术未来路在何方？
1434
flink1.20.0 部署后发布报错，是怎么回事，各种配置都配置了
183
数据来源：com.alibaba.fastjson.JSONException: syntax er
5607
Caused by: org.apache.kafka.common.errors.TimeoutE
3297
大佬，Caused by: java.lang.ClassNotFoundException: or
506
dataworks里面的stg层、ods层、dwd层、dws层、是怎么分层的呢？
2661
请教一下DataWorks，doris和starRocks 选型，选哪个？
1452
Flink 集群重启后，所有的Jobs任务全都没有了。如果快速恢复所有的任务
1245
请问flink-connector-jdbc在sink时，如何设置批量写入？
3137
Apache Flink未授权访问上传导致的RCE漏洞，这个漏洞目前方案解决吗？
588
展开全部
MaxComputeSql性能调优
7476
探寻独角兽背后的大数据力量— 阿里巴巴大数据计算线下Meetup（杭州站）干货集锦
3444
从HA3到AI·OS -- 全图化引擎破茧之路
7608
超强攻略！看完拿 Apache Flink 极客挑战赛全场最佳「MVP」
3113
如何在Windows和Mac上免费将蓝光转换为MKV？
1482
【译】Spark Streaming 框架在 5G 中的应用
1449
什么是HTTP代理？HTTP代理的作用？HTTP代理怎么设置？
7888
Ubuntu 报错：System has not been booted with systemd as init system (PID 1). Can‘t operate.
2050
ultralytics YOLO11 全新发布！（原理介绍+代码详见+结构框图）
766
【若依Java】15分钟玩转若依二次开发，新手小白半小时实现前后端分离项目，springboot+vue3+Element Plus+vite实现Java项目和管理后台网站功能
2604
展开全部
相关文章
相关电子书
更多
