在YARN群集中提交作业之前,Flink TaskManagers不会启动-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

在YARN群集中提交作业之前,Flink TaskManagers不会启动

2018-12-10 11:22:00 2412 1

我正在使用Amazon EMR在YARN上运行Flink Cluster。我的设置包含1个主节点和2个核心节点的m4.large实例。我已经使用以下命令在YARN上启动了Flink CLuster : flink-yarn-session -n 2 -d -tm 4096 -s 4.

Flink作业管理器和应用程序管理器启动但没有任务管理器在运行。Flink Web界面显示0可用于任务管理器,任务槽和可用插槽。但是,当我向flink群集提交作业时,会分配任务管理器并运行作业,Web UI会按预期显示正确的值,并在作业完成后返回0。

我希望任务管理器即使在没有提交作业时也能运行,因为我想使用Flink的REST API来监视和修改基于可用插槽值的并行性。

是否有我错过的配置阻止任务管理器一直运行?

取消 提交回答
全部回答(1)
  • flink小助手
    2019-07-17 23:19:07

    在FLIP-6中改变了Flink的行为以允许动态资源分配。从Flink版本1.5.0开始,可以mode: legacy使用flink-conf.yaml在旧模式下运行Flink,其中任务管理器将与作业管理器一起启动。

    0 0
相关问答

2

回答

各位线上Flink作业的监控报警是怎么做的?

2019-12-19 19:13:20 2247浏览量 回答数 2

1

回答

Flink CDC中的CDC是什么意思?

2022-01-19 15:15:09 4551浏览量 回答数 1

1

回答

Flink CDC 的亮点之一是什么?

2022-01-19 16:21:12 601浏览量 回答数 1

1

回答

Flink CDC 的核心特性有哪些?

2022-01-19 16:17:42 585浏览量 回答数 1

1

回答

有关 Flink CDC 的介绍和教程可以在哪里参考到?

2022-01-19 16:35:16 1521浏览量 回答数 1

1

回答

Flink CDC 的下游支持了哪些数据源?

2022-01-19 16:09:35 753浏览量 回答数 1

1

回答

Flink CDC 和 Flink 的版本对应关系是怎么样的?

2022-01-19 16:25:14 1252浏览量 回答数 1

1

回答

Flink CDC Connectors是什么技术?

2022-01-19 15:39:18 666浏览量 回答数 1

1

回答

flink 1.11 cdc相关问题

2021-12-07 10:07:48 693浏览量 回答数 1

1

回答

Flink1.11支持CDC了是么? #Flink

2020-06-10 23:24:45 1711浏览量 回答数 1
+关注
flink小助手
flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。
文章
问答
问答排行榜
最热
最新
相关电子书
更多
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》
立即下载
实时即未来-Apache Flink 年度最佳实践
立即下载
实时即未来-Apache Flink年度最佳实践
立即下载