【发布时间】：2021-10-21 00:38:09
【问题描述】：
我使用 Flink1.8 for java 来执行有状态计算。我的状态存储在 RocksDB 中。我是否可以确定每个操作员维护的状态的大小？我的意图是自动/定期报告每个操作员的总状态大小，并在它们发生巨大变化时触发警报。
【问题讨论】：
标签： apache-flink flink-streaming rocksdb
【发布时间】：2021-10-21 00:38:09
【问题描述】：
你可以在 Flink 的 REST API 中使用这个端点：
/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid
有关更多信息，请参阅 Flink 1.8 文档：https://ci.apache.org/projects/flink/flink-docs-release-1.8/monitoring/rest_api.html#jobs-jobid-checkpoints-details-checkpointid-subtasks-vertexid
【讨论】：