Flink作业管理器和任务管理器在本地托管在哪里？
我让Flink服务器在端口8081上本地运行。我在上面部署了我的flink应用程序的jar，它成功运行。
现在，我需要听取普罗米修斯的Flink指标，为此，我需要将作业管理器和任务管理器配置为普罗米修斯的目标。yml。
那么，我在哪里可以获得相同的端口？
共有1个答案
配置文件etc/prometheus/prometheus。yml仅在放置JM的主机上，并将TM的IP作为目标。在我的示例中，JM位于本地主机，TM位于本地主机、192.168.56.101、192.168.56.102和192.168.56.103。
global:
scrape_interval: 15s
scrape_configs:
- job_name: 'prometheus'
scrape_interval: 5s
static_configs:
- targets: ['localhost:9090']
- job_name: 'flink'
scrape_interval: 5s
static_configs:
- targets: ['localhost:9250', 'localhost:9251', '192.168.56.101:9250', '192.168.56.102:9250', '192.168.56.103:9250']
metrics_path: /
您必须配置文件conf/flink-conf.yaml，以便在一系列端口上将数据导出到Prometheus。此链接详细解释。
# Metrics Reporter
metrics.reporter.prom.class: org.apache.flink.metrics.prometheus.PrometheusReporter
metrics.reporter.prom.host: 127.0.0.1
metrics.reporter.prom.port: 9250-9260
-
我是flink的新手，我部署了我的flink应用程序，它基本上执行简单的模式匹配。它部署在库伯内特斯集群中，具有1个JM和6个TM。我每10分钟向eventhub主题发送大小4.4k和200k消息并执行负载测试。我添加了重启策略和检查点，如下所示，我没有在代码中显式使用任何状态，因为没有要求 最初，我遇到了网络缓冲区的Netty服务器问题，我遵循了以下链接https://ci.apache.org
-
我有一个Flink 1.2集群的设置，由3个JobManager1和2个TaskManager1组成。我从JobManager1开始动物园管理员法定人数，我得到确认，动物园管理员开始其他2个JobManager1，然后我在这个JobManager1上开始一个Flink作业。 flink-conf.yaml在所有5个虚拟机上都是相同的，这意味着jobmanager。rpc。地址：指向各处的JobMa
-
每个新创建的任务都是 org.gradle.api.DefaultTask 类型， org.gradle.api.Task 的标准实现，DefaultTask 所有的域都是私有的，意味着他们只能通过 setter 和 getter 方法来访问，庆幸的是Groovy提供了一些语法糖来允许你通过名字来使用域。 管理项目的版本 许多公司或者开源组织有他们自己的发布版本的措施，一般用主版本号和次版本号来表
-
用 ceph-deploy 建立一个集群后，你可以把客户端管理密钥和 Ceph 配置文件发给其他管理员，以便让他用 ceph 命令管理集群。 创建一管理主机 要允许一主机以管理员权限执行 Ceph 命令，用 admin 命令： ceph-deploy admin {host-name [host-name]...} 分发配置文件 要把改过的配置文件分发给集群内各主机，可用 config push
-
在San CLI中主要通过san serve和san build命令进行生产和开发环境的打包，San的脚手架工程内置了四个命令，包括启动本地服务、生产环境打包、打包分析、现代模式打包等，脚手架工程的package.json内可执行的命令有： npm run start // 打包+启动本地服务 npm run build // 打包发布 npm run analyzer // 打包分析 npm r
-
任务管理(又称 构建)工具 任务管理/构建 工具: Gulp Grunt Tasking/build and more tools: Brunch Mimosa