Skip to content

Commit

Permalink
fix unit test
Browse files Browse the repository at this point in the history
  • Loading branch information
zwangsheng committed Aug 9, 2023
1 parent 9d0d8fc commit a10b318
Showing 1 changed file with 4 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -122,9 +122,10 @@ private MemoryManager(CelebornConf conf) {
Preconditions.checkArgument(maxDirectorMemory > 0);
Preconditions.checkArgument(
pauseReplicateRatio > pausePushDataRatio,
"Invalid config, {} should be greater than {}",
CelebornConf.WORKER_DIRECT_MEMORY_RATIO_PAUSE_REPLICATE().key(),
CelebornConf.WORKER_DIRECT_MEMORY_RATIO_PAUSE_RECEIVE().key());
String.format(
"Invalid config, {} should be greater than {}",
CelebornConf.WORKER_DIRECT_MEMORY_RATIO_PAUSE_REPLICATE().key(),
CelebornConf.WORKER_DIRECT_MEMORY_RATIO_PAUSE_RECEIVE().key()));
Preconditions.checkArgument(pausePushDataRatio > resumeRatio);
Preconditions.checkArgument(resumeRatio > (readBufferRatio + shuffleStorageRatio));

Expand Down

0 comments on commit a10b318

Please sign in to comment.