cesco
cesco

Reputation: 3

Getting Flink cluster configuration at runtime

I'm interested in getting at runtime the number of TaskManagers and slots of a Flink cluster, before submitting jobs to it (I'd like to tune some program parameters based on the cluster ones).

Does anybody know which functions should I call to get these parameters?

Thanks!

Upvotes: 0

Views: 719

Answers (1)

Alex
Alex

Reputation: 859

The parameters are available through Flink's REST API.

Full API documentation: https://ci.apache.org/projects/flink/flink-docs-master/monitoring/rest_api.html

Upvotes: 1

Related Questions