回答情况：
提问时间：
问题标签：
在互联网上，我总是看到概念分支，但当我查看JobManager的源代码时(最新的代码来自master分支) Interface: JobManagerRunner
javadoc: InterfaceThe job master is responsible for the execution of a single 我想问代码中的JobMaster是否是互联网上JobManager的概念
浏览 48提问于2020-08-31得票数 1
回答已采纳
我从JobManager1启动Zookeeper仲裁，我确认Zookeeper在另外两个JobManagers上启动，然后我在这个JobManager1上启动一个闪烁作业。在所有5个虚拟机上，flink-conf.yaml都是相同的，这意味着jobmanager.rpc.address:指向JobManager1 everywhere。akka.tcp://flink@1.2.3.4:44779/user/jobmanager: Old JobManager
浏览 207修改于2017-03-15得票数 1
回答已采纳
根据我的理解，TaskManager恢复是由JobManager辅助的(这是预期的)，而JobManager恢复是通过Zookeeper完成的。我可以等待单个JobManager重新启动。
浏览 16提问于2018-09-07得票数 1
回答已采纳
JobManager HA上的最新Flink 1.9 doc仅涵盖单机版和纱线版。我正在寻找如何在Kubernetes上启用HA。
浏览 49修改于2020-06-08得票数 1
我无法设法使TaskManager与码头群堆栈上的JobManager通信。用于stack.yml的docker stack deploy文件的内容如下：services: image: affo/flink:1.1.3然而，没有一个TaskManager能够通过JobManager。和一个TaskManager：的日志
JM的VIP为10.0.42.7。jobmanager.
浏览 0修改于2017-02-09得票数 4
当我启动集群时，一切都如期而至，每个JobManager和TaskManager荚都成功地进入了运行状态，我可以从主JobManager的web中看到连接的TaskManager实例。但是，当我删除主JobManager的结束符时，另一个JobManager pod不能在集群中的任何JobManager上选择具有以下错误消息的领导者。
浏览 1修改于2018-09-08得票数 4
关于向现有运行的集群中添加新的Task/JobManager，可以在这里找到这个过程()。
但是，如果我们关闭集群并再次启动它，将丢失有关添加的主机的信息。
浏览 1修改于2017-04-13得票数 1
回答已采纳
这个母版(JobManager)启动，并通过ssh向所有从站发送开始命令。我可以看到，任务管理器是在主节点启动后运行的。所有节点上的配置文件：jobmanager.rpc.port: 6123taskmanager.heap.mb2048taskmanager.memory.preallocate: false
parallelism.d
浏览 6提问于2016-07-21得票数 3
回答已采纳
emr-6.1.0 (1个主节点，4个核心节点)安装的应用程序: FLINK 1.11.0Beginning with Amazon EMR version 5.28.0, JobManager
浏览 0修改于2020-09-28得票数 1
回答已采纳
AEM6.2.我有一个Osgi Service，其中在org.apache.sling.event.jobs.JobManager中引用了job并将其添加到其中。Object>();props.put("count", 5);
jobManager.addJob
浏览 24修改于2019-05-23得票数 0
回答已采纳
我已经在HA模式中配置了Flink，正如前面提到的
2018-07-25 19:46:08,508 INFO org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messag
浏览 0修改于2018-07-27得票数 4
Flink官方文档为单机版和Yarn Flink集群提供了jobmanager高可用性解决方案。但是，使用Mesos Flink集群应该如何实现高可用性？我了解到Flink依赖于马拉松来带来失败的JobManager，但它也有一个问题:每次作业管理器重新启动时，作业都会被重新部署。这对于任务关键型作业是不可接受的。是否有解决此问题的方法？
浏览 25提问于2019-03-13得票数 0
，如果JobManager失败了怎么办？如果JobManager失败了，所有的TaskManagers也会失败吗？如果是这样的话，当我在动物园管理员的帮助下恢复JobManager时，执行所有TaskManagers，它们的任务将继续运行
浏览 2提问于2020-07-29得票数 1
回答已采纳
我想在删除flink作业群集之前/之后删除所有rocksdb文件。我们在K8s上部署了flink作业。我们将每个作业集群的状态存储在rocksdb上。并且当作业集群停止时，存储状态的rocksdb不会被删除。有什么想法吗？
浏览 39修改于2020-02-21得票数 0
回答已采纳
我应该在flink- both . them / jobmanager.rpc.address中说明这两种情况吗？如果是，怎么做？
浏览 0修改于2018-08-08得票数 1
回答已采纳
/bin/flink run WordCount.jar
并在执行几分钟后给我一个“与JobManager通信失败的错误”。org.apache.flink.client.program.ProgramInvocationException: The program execution failed: Communication with JobManagerfailed: Lost connection to the JobManager.failed: Lost connection to the JobMa
浏览 1修改于2015-12-17得票数 3
下面是flink conf， jobmanager.rpc.port: 6123taskmanager.rpc.port: 6122jobmanager.memory.process.size: 5120mtaskmanager.memory.process.sizetaskmanager.memory.framework.off-heap.
浏览 218提问于2021-09-09得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号