Flink监控：捕获统计数据5分钟以上
我是Flink社区的新成员，我正在尝试进行一项实验研究，以捕获Flink在流数据方面的性能。为此，我试图收集几个小时内运行作业的统计数据。然而，使用Flink的UI，我只能看到过去5分钟的统计数据。我尝试访问Rest API，但它不包含除读/写字节以外的统计数据。
UI中任务度量下提供的度量非常有用，但不会超过5分钟。是否有一种方法可以捕获度量的整个历史记录。
共有1个答案
您可以配置指标报告器以记录您在任何时间段内感兴趣的所有指标。
Flink 1.3配备了JMX、Ganglia、Graphite、StatsD和DataDog的记者。本文档介绍如何配置报告器。
-
监控统计界面入口 控制台->结构化存储->下图中的“统计监控”按钮 监控统计指标 监控统计支持观测表的各项指标，目前支持（监控界面从上至下)： 允许读/拒绝读 允许写/拒绝写 操作成功/操作失败 读吞吐/读延迟 写吞吐/写延迟 增量吞吐/增量延迟 删除吞吐/删除延迟 扫描吞吐/扫描延迟 批处理吞吐/批处理延迟 监控统计单位 SDS的“监控统计”采用的是指数加权移动平均法(EWMA)，目前有一下两种
-
WeX5能开发手机游戏app吗？ 不用怀疑，下面跟我一起来用WeX5实现“欢乐捕鱼app”吧 游戏资源准备 “捕鱼案例“(案例来自github上的quark-dev-team) >>点此下载，下载后，在UI2下创建fishJoy目录，将下载的文件解压到fishJoy目录下，形成的目录结构如下： 创建本地App工程 在Native上右键，选择“新建–>创建本地App”，过程如下： 生成App 在Na
-
我想统计一下每分钟存储的新文档数量。 由于带有标准ObjectID的_id字段已经包含文档创建的时间戳，我认为应该可以以某种方式使用它。 在Stackoverflow上，我发现了以下映射缩减代码，以便在创建数据有专用字段时完成它 地图-减少每分钟的文档数MongoDB 根据Mongo DB文档(http://docs.mongodb.org/manual/reference/object-id/)
-
问题内容： 我需要查询方面的帮助，比方说这是表中的数据。 我想获得至少比最后一行晚5分钟的每一行（时间戳）。在这种情况下，查询应返回： 问题答案： 递归CTE 由于每一行都取决于之前的一行，因此很难使用基于集合的方法来解决。求助于递归CTE（这是标准SQL）： 请注意我的初稿中的更新： 递归CTE中不允许使用聚合函数。我用/代替，当/上的 索引 支持时应该很快。 查询每条腿周围的括号对于允许是必须
-
问题内容： 我需要在应用程序中收集一些统计信息。我有一个用户表（tb_user），每当一个新用户访问该应用程序时，它将在该表中添加一条新记录，即每个用户一行。主要字段是 id 和 date_hour （用户首次访问该应用程序的时间戳）。 tb_user 我需要得到： 按日，周和月划分的平均用户数 例子： 每天：55.45 每周：XX.XX 月：XX.XX 编辑： 我最好的解决方案是： 但是，此解决
-
获取小程序概况趋势： $app->data_cube->summaryTrend('20170313', '20170313') 开始日期与结束日期的格式为 yyyymmdd。 API summaryTrend(string $from, string $to); 概况趋势 dailyVisitTrend(string $from, string $to); 访问日趋势 weeklyVisitT