当前位置: 首页 > 知识库问答 >
问题:

Apache Flink:Cassandra Sink度量

端木望
2023-03-14

我用Cassandra Sink写了一个Flink应用程序。一切都工作得很好,但是没有生成各种度量标准(如Latency、NumRecordsInPerSecond,等等)。

我真的需要Flink提供的延迟度量,但它没有显示任何数据。

我需要做一些其他的事情来让其他的图表工作吗?尤其是潜伏期。

共有1个答案

张星洲
2023-03-14

确保您没有禁用LatencyMarker。默认情况下,LatencyMarker将每2秒发出一次,以计算每个运算符的延迟。您可以设置通过env.getconfig().SetLatencyTrackingInterval(1000L);发送LatencyMarker的间隔

 类似资料:
  • 目前Spring Cloud Sleuth注册了与spans相关的简单指标。它使用Spring Boot的指标支持 来计算接受和删除的数量spans。每次发送到Zipkin时,接受的spans的数量将增加。如果出现错误,那么删除的数字spans将会增加。

  • 如spring-boot文档所述。我的自定义计数器(counter.calls.hello)像预期的那样起到计数器的作用。 现在,如果我将spring-cloud-starter-eureka(Brixton.rc1)添加到pom中,并且不更改任何其他内容,那么metricsendpoint将具有 正常的MVC度量标准已经消失了。响应代码信息呢?我的自定义计数器被报告为gauge.servo.co

  • Storm 开放了一个 metrics 接口,用来汇报整个 topology 的汇总信息 。 Storm 内部通过该接口可以跟踪各类统计数据:executor 和 acker 的数量;每个 bolt 的平均处理时延、worker 节点的堆栈使用情况,这些信息都可以在 Nimbus 的 UI 界面中看到。 Metric Types Metrics 必须实现 IMetric接口,IMetric接口只包

  • 组件的高度和宽度决定了其在屏幕上显示的尺寸。 指定宽高 最简单的给组件设定尺寸的方式就是在样式中指定固定的 width 和 height 。React Native 中的尺寸都是无单位的,表示的是与设备像素密度无关的逻辑像素点。 export default class HelloWorld extends Component { render() { return ( <

  • 在机器学习的算法评估中,尤其是分类算法评估中,我们经常听到精确率(precision)与召回率(recall),RoC曲线与PR曲线这些概念,那这些概念到底有什么用处呢? 首先,我们需要搞清楚几个拗口的概念: 1. TP, FP, TN, FN   True Positives,TP:预测为正样本,实际也为正样本的特征数   False Positives,FP:预测为正样本,实际为负样本的特征数

  • 主要内容:1. width,2. height,3. max-width 和 max-height,4. min-width 和 min-heightCSS 尺寸属性指的就是元素的宽度和高度属性,虽然说非常简单,但却是必须掌握的技能。CSS 中提供了 width、height、max-width、min-width、max-height 和 min-height 等几个属性来设置元素的宽度和高度,这些元素使用起来非常简单,下面我们就来简单介绍一下。 1. width 通过 width 属性可以设

  • 问题 你需要实现弧度和度之间的转换。 解决方案 使用 JavaScript 的 Math.PI 和一个简单的公式来转换两者。 # 弧度转换成度 radiansToDegrees = (radians) -> degrees = radians * 180 / Math.PI radiansToDegrees(1) # => 57.29577951308232 # 度转换成弧度 degr

  • 问题内容: 如何在Java中计算两个角度量度(以度为单位)的差,使结果在[0°,180°]范围内? 例如: 问题答案: /* * Shortest distance (angular) between two angles. * It will be in range [0, 180]. / public static int distance(int alpha, int beta) { int