我感兴趣的是在运行时获取flink集群的TaskManager和插槽的数量，然后再将作业提交给它（我想根据集群参数调整一些程序参数）。有人知道我应该调用哪些函数来获取这些参数吗？谢谢！
xhv8bpkk1#
这些参数可以通过flink的restapi获得。完整的api文档：https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html
1条答案
按热度按时间xhv8bpkk1#
这些参数可以通过flink的restapi获得。
完整的api文档：https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html