监控Apache Flink应用程序(入门)..................................... 9 4 进度和吞吐量监控 ......................................................................................... 10 4.1 吞吐量 .............................................. – 监控Apache Flink应用程序(入门) 进度和吞吐量监控 – 10 3 https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/stream/operators/#task-chaining-and-resource-groups 4 进度和吞吐量监控 知道您的应用程序正在运行并且检查点正常工作是件好事, 但是它并不能告诉您应用程序是否正在实际取得进 展并与上游系统保持同步。 4.1 吞吐量 Flink提供了多个metrics来衡量应用程序的吞吐量。对于每个operator或task(请记住:一个task可以包含多个 chained-task3),Flink会对进出系统的记录和字节进行计数。在这些metrics中,每个operator输出记录的速率 通常是最直观和最容易理解的。 4.2 关键指标0 码力 | 23 页 | 148.62 KB | 1 年前3
Flink如何实时分析Iceberg数据湖的CDC数据流o增量l入 更新频率 T频更新 高频更新 pache Iceberg feCDCBA方案nd考b的mo? 保g Iceberg c数R和 源c数R最终一a性 正确性 支持并DBA 吞吐量i够大 pTBA PartitionOBucket级C 并DMerge-On-Rea- Mkh取 支持I量P取便于进一 步数RTransform I量h Apache Iceberg0 码力 | 36 页 | 781.69 KB | 1 年前3
共 2 条
- 1













