Hi Mans, IMO, one job manager represents one Flink cluster and one Flink cluster has a suite of Flink configuration e.g. metrics reporter.
Some metrics reporters support tag feature, you can specify it to distinguish different Flink cluster.[1] [1]: https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#datadog-orgapacheflinkmetricsdatadogdatadoghttpreporter Best, Vino M Singh <mans2si...@yahoo.com> 于2019年12月19日周四 上午2:54写道： > 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 > <https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#system-scope>) > and and see the following: > > Apache Flink 1.9 Documentation: Metrics > > > <https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#system-scope> > > - metrics.scope.jm > - Default: <host>.jobmanager > - Applied to all metrics that were scoped to a job manager. > - > > ... > List of all Variables > <https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/metrics.html#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 > >
