apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CELEBORN-348][FOLLOWUP] Refine comparator to support nanoseconds whi… (#1305)

Browse Source
This commit is contained in:
Keyong Zhou 2023-03-03 17:55:59 +08:00 committed by GitHub
parent 88976d9fd9
commit 9608a11819
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java
View File

@ -262,12 +262,12 @@ public class SlotsAllocator {
double fetchTimeWeight) {
List<List<DiskInfo>> diskGroups = new ArrayList<>();
usableDisks.sort(
(o1, o2) ->
Math.toIntExact(
(long)
((o1.avgFlushTime() * flushTimeWeight + o1.avgFetchTime() * fetchTimeWeight)
- (o2.avgFlushTime() * flushTimeWeight
+ o2.avgFetchTime() * fetchTimeWeight))));
(o1, o2) -> {
double delta =
(o1.avgFlushTime() * flushTimeWeight + o1.avgFetchTime() * fetchTimeWeight)
- (o2.avgFlushTime() * flushTimeWeight + o2.avgFetchTime() * fetchTimeWeight);
return delta < 0 ? -1 : (delta > 0 ? 1 : 0);
});
int diskCount = usableDisks.size();
int startIndex = 0;
int groupSizeSize = (int) Math.ceil(usableDisks.size() / (double) diskGroupCount);