问答 2021-12-08 来自:开发者社区

flink集群模式下如何动态添加taskmanager

各位大神: 在flink集群部署时,有1个jobmanager,有2个taskmanager(slave1,slave2), 现在想添加slave3作为 taskmnanager。如何在不停止集群的情况下,可以像spark一样动态添加吗? 步骤是怎么样的?*来自志愿者整理的flink邮件归档

问答 2021-12-08 来自:开发者社区

flink-1.12.1 k8s Session集群模式没有生成Stdout输出文件

我参考: https://ci.apache.org/projects/flink/flink-docs-release-1.12/deployment/resource-providers/standalone/kubernetes.html 部署了一个session集群,运行任务。 在UI查看Stdout是空的,没有生成 .out 文件 请问是哪里配置的问题吗?*来自志愿者整理的flin...

问答 2020-07-09 来自:开发者社区

我们项目部署的flink集群是standalone模式的,因为之前运维的人离职了刚接手也#Flink

我们项目部署的flink集群是standalone模式的,因为之前运维的人离职了刚接手也不太熟悉,完了今天UI界面的job挂了,可以搞一个什么报警系统什么的吗,比如挂了给我发个短信什么的,网上没啥资料,有人可以指教一下吗? #Flink

问答 2019-07-01 来自:开发者社区

在flink集群模式下,能不能指定某个节点的solt来执行一个task?

因为我需要将flink处理结果输出到本地文件,在集群模式下,能否指定某一个固定节点来执行输出文件的task呢?writeAsFormattedText(localPath).setParallelism(1);

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等