celeborn/worker
liangbowen bbea692565
[CELEBORN-1066] Skip looping streamimg sets in numShuffleSteams of ChunkStreamManager
### What changes were proposed in this pull request?

- Minor improvement in `ChunkStreamManager.numShuffleSteams`, by replacing `.flatMap(Set::stream).count()` to `.mapToLong(Set::size).sum()`

### Why are the changes needed?

### Does this PR introduce _any_ user-facing change?

No.

### How was this patch tested?

CI tests.

Closes #2013 from bowenliang123/numShuffleSteams.

Authored-by: liangbowen <liangbowen@gf.com.cn>
Signed-off-by: zky.zhoukeyong <zky.zhoukeyong@alibaba-inc.com>
2023-10-23 11:15:18 +08:00
..
src [CELEBORN-1066] Skip looping streamimg sets in numShuffleSteams of ChunkStreamManager 2023-10-23 11:15:18 +08:00
pom.xml [CELEBORN-977] Support RocksDB as recover DB backend 2023-09-19 09:20:33 +08:00