Skip to content

Commit

Permalink
Add metrics sink to job master
Browse files Browse the repository at this point in the history
### What changes are proposed in this pull request?

Adding metrics sink to job master.

### Why are the changes needed?

Fix the issue that the job master is unable to sink metrics.

### Does this PR introduce any user facing changes?

Yes, this change will enable users to sink metrics from the job master.

pr-link: #16899
change-id: cid-7394471270d4617007eeb97e1674b90585337624
  • Loading branch information
ssyssy committed Feb 21, 2023
1 parent f9cb6df commit 73f3ce8
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions job/server/src/main/java/alluxio/master/job/JobMaster.java
Original file line number Diff line number Diff line change
Expand Up @@ -184,6 +184,10 @@ public long getNewJobId() {
@Override
public void start(Boolean isLeader) throws IOException {
super.start(isLeader);

// Start serving metrics system, this will not block
MetricsSystem.startSinks(Configuration.getString(PropertyKey.METRICS_CONF_FILE));

// Fail any jobs that were still running when the last job master stopped.
for (PlanCoordinator planCoordinator : mPlanTracker.coordinators()) {
if (!planCoordinator.isJobFinished()) {
Expand Down

0 comments on commit 73f3ce8

Please sign in to comment.