Skip to content

Commit

Permalink
style
Browse files Browse the repository at this point in the history
  • Loading branch information
s0nskar committed Nov 26, 2024
1 parent 21d9eaf commit e4d9ff0
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,8 +66,7 @@ public void init(Context context) throws IOException {
applicationAttemptId,
IOBufferSize);
UserIdentifier userIdentifier =
new UserIdentifier(
celebornConf.userSpecificTenant(), celebornConf.userSpecificUserName());
new UserIdentifier(celebornConf.userSpecificTenant(), celebornConf.userSpecificUserName());

final float spiller = jobConf.getFloat(JobContext.MAP_SORT_SPILL_PERCENT, (float) 0.8);
int pushSize = (int) ((IOBufferSize << 20) * spiller);
Expand Down

0 comments on commit e4d9ff0

Please sign in to comment.