Hi:
I am using AWS EMR with Flink application and two of the job managers are
running on the same host. I am looking at the metrics documentation (Apache
Flink 1.9 Documentation: Metrics) and and see the following:
|
|
| |
Apache Flink 1.9 Documentation: Metrics
|
|
|
- metrics.scope.jm
- Default: <host>.jobmanager
- Applied to all metrics that were scoped to a job manager.
-
...
List of all Variables
- JobManager: <host>
- TaskManager: <host>, <tm_id>
- Job: <job_id>, <job_name>
- Task: <task_id>, <task_name>, <task_attempt_id>, <task_attempt_num>,
<subtask_index>
- Operator: <operator_id>,<operator_name>, <subtask_index>
My question is there a way to distinguish b/w the two job managers ? I see only
the <host> variable for JobManager and since the two are running on the same
host, the value is the same. Is there any other variable that I can use to
distinguish the two.
For taskmanager I have taskmanager id but am not sure about the job manager.
Thanks
Mans
