我正在尝试使用Flinks监控REST API来检索特定时间段的一些指标。查看documentation，我可以通过导航到http://hostname:8081/jobs/:jobid找到该作业的指标，我有以下内容： {
"jid":"692c1d818afb77daaca891484e0b6a7g我想知道是否有从特定start-time和end-time请求指标<
浏览 22提问于2019-10-09得票数 0
回答已采纳
我试图收集一些关于云任务和作业的统计数据和性能指标，这些数据和作业是我提交给Azure批处理池的。为此，我使用的是内置的TaskExecutionInformation和TaskStatisitics类，但我对如何通过这些类计算某些指标感到困惑。具体来说，我想知道我的每个任务执行需要多长时间，所以我检查了内置到task.stat
浏览 1提问于2017-07-07得票数 0
在使用命令行将作业提交给Flink时，是否有任何方法来测量Apache中的作业执行时间？
PS。我希望flink API给我时间，而不是通过记录开始和结束时间来自己用bash度量它。
浏览 3提问于2015-12-12得票数 7
回答已采纳
我用Flink实现了一个模式，它匹配三个事件，比如A->B->C。在定义了我的模式之后，我生成一个有了这样一个PatternSelectFunctionpatternStream.select(new MyPatternSelectFunction()).print();
这就像一种魅力，但我对所有匹配事件的活动时间感兴趣。我知道传统的<
浏览 0提问于2019-01-21得票数 1
回答已采纳
2回答
我已经为在Intellij IDEA中运行的应用程序设置了Flink UI。我想获得一些流指标，如-调度延迟和处理时间。但是，我在UI中找不到anywhere。应该有一些具体的设置，或者我应该显式地提交app jar？ 目前，该作业的Flink UI如下所示： ?
浏览 25提问于2020-01-21得票数 0
回答已采纳
我有一个用例，我想用预先确定的开始时间和结束时间来计算窗口。例如，我想计算4月1日下午1点到4月7日下午1点之间的所有事件 我认为我可以计算每天的窗口，并保持结果的状态，但这似乎是最优的。Flink是否支持预定开始和结束时间的时间窗口？
浏览 10提问于2021-04-12得票数 0
回答已采纳
我正在尝试找出Apache Flink的关键健康指标是什么。Flink文档提供了大量的指标列表，很难找出重要的指标。
浏览 29提问于2019-02-01得票数 1
回答已采纳
2回答
,y)->3) .print();我正在写一个flink演示来开始使用flink，我有几件事我不明白：2、，窗口长度为4秒，滑动长度为1秒，我
浏览 2提问于2020-07-30得票数 0
配置:我有一个度量来报告请求持续时间，我有两个自定义事件设置来显示开始时间和结束时间，并且每个事件都填充了与请求相关的信息。
问题:我有一个指标，用于报告较长的请求持续时间。但是，对于将度量与操作的事件和依赖关系关联起来，洞察力的列表并不友好。我希望找到这两个事件之间的持续<
浏览 1提问于2016-06-02得票数 2
回答已采纳
1回答
我是Flink社区的新手，我正在尝试做一项实验研究，以捕获Flink对流数据的性能。为此，我尝试收集几个小时内正在运行的作业的统计数据。但是，使用Flink的UI，我只能看到过去5分钟的统计数据。我尝试访问Rest API，但它不包含除读取/写入字节以外的统计数据。
任务指标下的UI中提供的指标非常有用，但扩展
浏览 3提问于2017-11-15得票数 0
1回答
除了这个question之外，我还创建了这个示例来集成DataStreamAPI和TableAPI，这一次我没有出错，而且我有两个作业而不是一个，一个作业是为运行正常的DataStreamAPI创建的，另一个作业是为运行正常的TableAPI创建的，但唯一的问题是永远不会从DataStreamAPI收到任何值，示例： /*FILTERING NULL IDs*/
finalInit.
浏览 39提问于2020-09-08得票数 0
回答已采纳
在KDA (kakfa --> flink(beam) --> ElasticSearch)上运行一个闪烁光束作业这个简单的作业不会在KDA上启动并进入无限循环。AWS KDA支持回复说，作业在启动期间读取记录，这是失败的原因。 该应用程序的停靠版本在kubernetes中的3个任务管理器上运行得很流畅，但在KDA上则不是。因为KDA有2分钟的超时时间来启动作业。 根据我的</e
浏览 25提问于2021-02-09得票数 0
回答已采纳
我有一个作业跑步应用程序，它整天偶尔运行作业，我正在报告它们的指标。它们不连续运行，所以AI在间隙之间插入，图形看起来很奇怪。我希望图表不是插值，就是开始/结束于零，所以现在我将尝试在作业前后报告非预聚集的零值，所以至少这个插值将在图的底部，并且更容易阅读。是否有正确的方法来指示一个值段的结束和另一个值的开始<
浏览 4提问于2020-01-16得票数 0
回答已采纳
1回答
我有一个Spring批处理作业，它从DB读取记录，处理它，并写入另一个数据库。我想测量Spring批处理程序和Writer中的总时间/平均时间。根据文档- ，使用spring.batch前缀可以很容易地获得指标。如何将处理器和编写器所需的时间记录到控制台。当我在作业侦听器结束时打印来自度量注册表的Metrics结果时，我看到作业
浏览 5提问于2020-11-17得票数 2
回答已采纳
到目前为止，我已经知道了如何提交在构建作业中创建的jar文件。现在，我想找到任何与旧jar一起运行的Flink作业，优雅地停止它们，并利用我的新jar开始一个新的工作。API具有列出作业、取消作业和提交作业的方法。但是，似乎没有停止作业端点。对于如何优雅地停止使用API的作业
浏览 4提问于2017-08-04得票数 2
回答已采纳
使用Prometheus度量需要一种不同的思维方式。设计度量标准通常并不太困难。你能帮我设计一个订单处理系统的指标吗？我如何
浏览 1提问于2019-10-24得票数 0
回答已采纳
1回答
我从我的.jar文件运行多个作业。我想在我的工作之间共享状态。但是所有输入在每个作业中都会消耗(来自kafka)，并生成重复的输出。我看到了flink面板。所有的工作‘记录发送’是3。我想必须拆分数字到我的工作。 我使用此命令创建作业 bin/flink run app.jar 我怎么才能修复它？
浏览 46提问于2019-09-29得票数 0
回答已采纳
我有一个用scala编写的flink作业，我正在创建一个自定义度量来计算流中事件的nmber。任务部署在kubernetes上，我看到prometheus中作业经理和任务经理的系统度量。*的任何任务管理器度量都不会在度量端点中公开。/bin/bash我只获得与任务管理器相关的状态度量：
# HELP fli
浏览 18提问于2022-11-10得票数 0
回答已采纳
我使用以下代码来请求数据：$ga->requestReportData($ga_profile_id,'date',arrayresults = $ga->getResults();在谷歌搜索之后，我似乎找不到答案，或者有可能得到总访问量、页面浏览量、新访问量、独特性、新访问量百分比……在一定的时间范围内
浏览 0提问于2013-11-18得票数 0
1回答
，这似乎在流用例中工作得很好:转移结束后出现的第一个事件触发了最后一次转移的触发和聚合。当这类事情发生时，我注意到最后一个窗口没有被触发/刷新，
Flink<
浏览 2提问于2020-11-06得票数 0
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
