如何知道我的flink作业在哪个任务管理器上运行？
在Flink中，可以通过Flink的Web界面或者命令行工具来查看你的作业在哪个任务管理器上运行。
- 使用Flink的Web界面：
- 打开Flink的Web界面，通常是通过访问
http://<flink-web-ui>:8081来访问。 - 在Web界面的导航栏中选择"Jobs"选项卡。
- 在"Jobs"页面中，你可以看到所有正在运行的作业。
- 找到你感兴趣的作业，并点击作业的名称。
- 在作业的详情页面中，你可以看到作业的运行状态、所在的任务管理器以及其他相关信息。
- 打开Flink的Web界面，通常是通过访问
- 使用Flink的命令行工具：
- 打开终端或命令行界面。
- 使用
flink list -r命令来列出所有正在运行的作业及其相关信息。 - 找到你感兴趣的作业，并查看其所在的任务管理器。
需要注意的是，以上方法都是在作业正在运行时才能查看到作业所在的任务管理器。如果作业已经完成或者失败，那么你将无法获取到作业所在的任务管理器信息。
推荐的腾讯云相关产品：腾讯云Flink Serverless计算，产品介绍链接地址：https://cloud.tencent.com/product/tcflinkserverless
相关·内容
我在flink纱线集群上运行一个flink作业，并行度设置为1，所以这个作业应该在一个任务管理器上运行，如何知道它在哪个任务管理器上运行？
浏览 28提问于2019-02-13得票数 1
回答已采纳
我在Docker上运行了Flink 1.2.1，任务管理器作为Docker群的一部分分布在不同的VM上。
我知道动态缩放在Flink中还不可用。因此，如果我想增加运行Flink任务管理器的容器的数量(向上扩展)，我
浏览 0提问于2017-10-22得票数 1
我正在用最新版本的flink 1.5在kubernetes上试用flink作业。我的问题是如何在上面的flink集群上
浏览 0提问于2018-06-22得票数 1
我们在应用程序模式下的Kubernetes上运行Flink作业，问题是当作业完成/停止时，作业管理器容器将退出，但1.任务管理器的部署2.作业管理器服务3.删除将仍然存在，除非我们运行kubectl configMap如果我们手动停止作业，这并不是什么大问题，但如果我们的Fl
浏览 5提问于2021-02-20得票数 0
我有一个独立的flink集群，运行在具有两个任务管理器的单个节点上。 在我启动了35个作业之后，我发现所有的作业都在一个任务管理器上运行。没有任务在另一个任务管理器上运行。 我<
浏览 24提问于2021-04-20得票数 0
回答已采纳
1回答
我使用以下命令在本机K8s上使用会话模式创建了一个Flink集群：基于。
我能够向集群提交作业并查看Flink UI。但是，我注意到，Flink只在作业提交时创建一个任务管理器</e
浏览 10提问于2022-08-30得票数 1
回答已采纳
我有一个基于Flink 1.4.2的Flink独立集群(1个作业管理器，4个任务槽)，并想提交两个不同的Flink程序。不确定这是否可能，因为一些flink归档文件说一个作业管理器只能运行一个作业。如果这是真的，我该如何解决这个问题呢？Flink集群只有一台机器可用，我们不想使用任何资源<em
浏览 2提问于2018-06-12得票数 3
我们在hadoop 2.6群集上运行Flink 1.5.0 Yarn会话。./bin/yarn-session.sh -n 4 -jm 1024 -tm 4096 -qu但是这不会启动任何任务管理器。日志上说Flink JobManager是从leader id 000000开始的...在JobManager web界面中也没有任务管理器。当我们向这个jobManager提交一个
浏览 10提问于2018-08-21得票数 0
1回答
我正在研究Flink 1.9.1的停靠/K8部署的可能性。目前，我们确实认为我们将尝试采用工作集群的方法，尽管我们想知道这个社区的趋势是什么？我们不希望每个Flink集群部署一个以上的作业。
如何更改职务和会话群集每个任务管理器的</
浏览 1提问于2020-01-10得票数 2
回答已采纳
我在Amazon EMR中运行Flink。在flink-conf.yaml中，我有metrics.reporter.prom.port: 9249-9250，这取决于作业管理器和任务管理器是否在同一节点上运行，任务管理器指标在端口9250 (如果与作业管理器
浏览 12提问于2018-08-31得票数 0
1回答
为了学习目的，我正在构建一个简单的数据管道。我有来自Kafka的实时数据，我想使用Flink进行一些转换。
Flink应用程序群集是<em
浏览 5提问于2022-01-08得票数 0
回答已采纳
在配置文件(job-manager- config /flink-conf.yaml，task-manager-config/flink-conf.yaml，job-manager-config/zoo.cfg，...)为了将Flink应用程序部署从会话模式更改为作业模式？此外，我们通过一个ansible角色在openshift上设置了flink集群，但不幸的是，它不是从ansible galaxy存储库
浏览 33提问于2019-09-06得票数 1
回答已采纳
我正在尝试设置一个flink-yarn会话来运行~100+批处理作业。在连接到大约40个任务管理器和大约10个正在运行的作业(每个任务管理器有2个插槽和1 1GB内存)后，看起来会话变得不稳定。有足够的可用资源。flink UI突然变得不可用，我猜作业管理器可能已经死了。最终，yarn应用程序
浏览 2提问于2020-08-16得票数 0
我在一个由3台机器组成的集群上使用Apache 1.4，其中一台是JobManager，另外2台是主机TaskManagers。
我在集群模式下启动flink并提交flink作业。我已经在flink配置中配置了24个任务槽，对于该任务，我使用了6个任务插槽。在代码中，我启用了
浏览 4提问于2018-01-15得票数 2
我们需要在Flink集群上运行10个作业，其中4个不是CPU限制的，所以对于它们，我们可以有2xcpu任务槽，然而，6个作业是CPU限制的，它们需要在每个任务管理器上使用大量的CPU，即vpcu/2个插槽我的问题是，我如何告诉Flink使用x台机器(任务管理
浏览 20提问于2021-07-26得票数 0
回答已采纳
假设我有一个包含3个节点的Flink集群。一个节点用于作业管理器，另外两个节点用于任务管理器。每个任务管理器有3个任务槽。因此，当我提交并行度等于2的作业时，Flink将分配两个任务槽。所以，我的问题是，Flink将如何分配这些任务槽？ 一些场景 F
浏览 13提问于2020-08-23得票数 0
回答已采纳
我有一个EC2实例，它位于us 1b中，正在运行flink作业管理器，它负责通过RPC跨多个任务管理器和历史服务器协调工作。安全组允许从组中的任何源到组中的任何目的地的所有端口上的所有通信：📷
我正在使用ASG作为ECS任务的容量提供者。然后，我试图在ECS中运行一个任务</em
浏览 0提问于2021-09-28得票数 0
回答已采纳
最近，我遇到了一些关于开发flink作业的问题，它引入了spring和hibernate，作业将在flink集群上运行。因此，在任务管理器上运行flink运算符之前，需要初始化spring资源，而不是作业manager.But，我找不到合适的StreamExecutionEnvironment方法来实现。以下是
浏览 4提问于2016-11-11得票数 4
正如描述的那样，我在Yarn上运行一个flink作业。使用上述参数-yn，我可以设置纱线节点/任务管理器的数量。但是，我想知道是否可以设置每个任务管理器的任务插槽数。当我使用pa
浏览 0提问于2018-05-04得票数 0
回答已采纳
我有4个任务管理器，并使用映射状态后端(RocksDB)。使用QueryableStateClient查询状态。1.如何获得正确的任务管理器来查询状态，而不是查询所有的任务管理器。(KvstateLocation )是否有人提供无法在文档中找到它的示例代码。
Flink 1.
浏览 0提问于2019-01-17得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
