Skip to content

Commit

Permalink
[CELEBORN-1800] Introduce ApplicationTotalCount and ApplicationFallba…
Browse files Browse the repository at this point in the history
…ckCount metric to record the total and fallback count of application
  • Loading branch information
SteNicholas committed Dec 25, 2024
1 parent 8d754e9 commit e698224
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -102,12 +102,12 @@ public void registerJob(JobShuffleContext context) {
celebornAppId = FlinkUtils.toCelebornAppId(lifecycleManagerTimestamp, jobID);
LOG.info("CelebornAppId: {}", celebornAppId);
lifecycleManager = new LifecycleManager(celebornAppId, conf);
lifecycleManager.applicationCount().increment();
this.shuffleResourceTracker = new ShuffleResourceTracker(executor, lifecycleManager);
}
}
}

lifecycleManager.applicationCount().increment();
try {
if (nettyShuffleServiceFactory != null) {
Optional<ShuffleFallbackPolicy> shuffleFallbackPolicy =
Expand Down

0 comments on commit e698224

Please sign in to comment.