问答 2023-04-19 来自:开发者社区

有人知道flink on yarn 的application模式怎么提交多个job组成应用程序呢?

有人知道flink on yarn 的application模式怎么提交多个job组成应用程序呢?

问答 2023-04-03 来自:开发者社区

flink单 机模式,为什么取消 job后,slot有时不释放呢。

flink单 机模式,为什么取消 job后,slot有时不释放呢。

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

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

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

问答 2022-02-15 来自:开发者社区

flink on yarn 的application模式怎么提交多个job组成应用程序呢?

1.flink on yarn 的application模式怎么提交多个job组成应用程序呢?在官网和论坛的文章中这里没有详细展开。 与per-job 模式相比,Application 模式允许提交由多个Job组成的应用程序。Job执行的顺序不受部署模式的影响,但受启动Job的调用的影响。使用阻塞的 execute()方法,将是一个顺序执行的效果,结果就是"下一个"Job的执行被推迟到“该”J.....

问答 2022-02-15 来自:开发者社区

Flink Session 模式Job日志区分

多个Job跑在一个Session中,如何区分不同job的日志呢?目前有什么好的办法吗?*来自志愿者整理的flink邮件归档

问答 2022-02-15 来自:开发者社区

flink on yarn session模式与yarn通信失败是什么问题? (job模式可以成功)

大佬们请教一下: 之前一直使用job模式来提交任务,可以顺利提交计算任务。最近有需求比较适合session模式来提交,按照论坛里的教程进行提交的时候,一直报错连接不上resource manage。观察启动log发现两种任务连接的resource manage不同,一个是正确的端口,一个一直请求本机端口。 session 模式启动log: job 模式启动log: 想请教一下: 1.如何配...

问答 2022-02-15 来自:开发者社区

Flink on Yarn 的 Session 模式和 Per Job 模式的应用场景有什么区别

Flink on Yarn 的 Session 模式和 Per Job 模式的应用场景有什么区别

问答 2022-02-15 来自:开发者社区

Flink On Yarn的模式下,如果通过REST API 停止Job,并触发savepiont呢

Flink On Yarn的模式下,如果通过REST API 停止Job,并触发savepiont呢? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

问答 2022-02-15 来自:开发者社区

Flink上执行storm拓扑,在yarn模式提交job时,找不到jobmanager

问题描述:Flink上执行storm拓扑,在yarn模式提交job时,找不到jobmanager-- 需求:storm的任务迁移到flink上,为了减少改动量,使用的flink兼容storm。-- 参考:https://flink.apache.org/news/2015/12/11/storm-compatibility.html-- 现象:无法正常提交job。从日志上看问题出在无法找到yar....

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

产品推荐

阿里云实时计算Flink

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

+关注