我正在运行以RocksDB作为我的状态后端的Apache的欺诈检测器示例。我想知道Apache需要多长时间来检查状态。
我的方法是在检查点功能之前和之后打印时间。
我找不到函数/类或任何代码来检查我试图通过IDE调试的状态,但是没有结果。
到目前为止,这就是我所经历的:
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for a
Flink Web UI有一个出色的背压部分。但我看不到任何指标,由普罗米修斯记者给出,可以用来检测背压的相同方式为Grafana仪表盘。 ? 有没有办法在Flink Web UI之外获得相同的指标?使用此处描述的指标https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html。或者甚至有一个普罗米修斯刮刀来抓取web api?
我设置了一个Flink工作,向Kafka主题写一些消息。它使用FlinkKafakProducer作为接收器。我验证了输出Kafka主题中写入了消息,但Flink指标numRecordsOut始终显示0。同样,在Flink Web UI中,发送的字节也始终显示0B。
记录输出数量不能反映实际数量的原因是什么?