查看各个算子维护的 Flink State 大小
View Size of Flink State Maintained By Each Operator
我使用 Flink1.8 java 来执行有状态计算。我的状态存储在 RocksDB 中。我是否有可能确定我的每个操作员所维护的状态的大小？我的目的是 automatically/regularly 报告每个算子的总状态大小，并在它们发生显着变化时触发警报。
您可以在 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
我使用 Flink1.8 java 来执行有状态计算。我的状态存储在 RocksDB 中。我是否有可能确定我的每个操作员所维护的状态的大小？我的目的是 automatically/regularly 报告每个算子的总状态大小，并在它们发生显着变化时触发警报。
您可以在 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