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 4d40188 commit 8d754e9
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
8 changes: 4 additions & 4 deletions common/src/main/proto/TransportMessages.proto
Original file line number Diff line number Diff line change
Expand Up @@ -444,8 +444,8 @@ message PbHeartbeatFromApplication {
repeated PbWorkerInfo needCheckedWorkerList = 5;
bool shouldResponse = 6;
int64 shuffleCount = 7;
int64 applicationCount = 8;
map<string, int64> shuffleFallbackCounts = 9;
map<string, int64> shuffleFallbackCounts = 8;
int64 applicationCount = 9;
map<string, int64> applicationFallbackCounts = 10;
}

Expand Down Expand Up @@ -682,8 +682,8 @@ message PbSnapshotMetaInfo {
map<string, PbApplicationMeta> applicationMetas = 16;
repeated PbWorkerInfo decommissionWorkers = 17;
int64 shuffleTotalCount = 18;
int64 applicationTotalCount = 19;
map<string, int64> shuffleFallbackCounts = 20;
map<string, int64> shuffleFallbackCounts = 19;
int64 applicationTotalCount = 20;
map<string, int64> applicationFallbackCounts = 21;
}

Expand Down
4 changes: 2 additions & 2 deletions master/src/main/proto/Resource.proto
Original file line number Diff line number Diff line change
Expand Up @@ -121,8 +121,8 @@ message AppHeartbeatRequest {
required int64 totalWritten = 3;
required int64 fileCount = 4;
optional int64 shuffleCount = 5;
optional int64 applicationCount = 6;
map<string, int64> shuffleFallbackCounts = 7;
map<string, int64> shuffleFallbackCounts = 6;
optional int64 applicationCount = 7;
map<string, int64> applicationFallbackCounts = 8;
}

Expand Down

0 comments on commit 8d754e9

Please sign in to comment.