Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[CELEBORN-1675] User with zero quota should not be allowed to submit any shuffle to cluster. #2857

Open
wants to merge 3 commits into
base: main
Choose a base branch
from

Conversation

Z1Wu
Copy link

@Z1Wu Z1Wu commented Oct 28, 2024

What changes were proposed in this pull request?

In current implementation, user with zero quota still can submit one shuffle to rss cluster.
It might be more reasonable to disallow users with a quota of 0 from submitting a shuffle to the RSS cluster.

Why are the changes needed?

Does this PR introduce any user-facing change?

No

How was this patch tested?

unit-test

Copy link
Contributor

@s0nskar s0nskar left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM! Please update the config docs to reflect the same.

@Z1Wu
Copy link
Author

Z1Wu commented Oct 29, 2024

LGTM! Please update the config docs to reflect the same.

updated

@s0nskar
Copy link
Contributor

s0nskar commented Oct 29, 2024

@Z1Wu You need to update the documentation as well using

UPDATE=1 build/mvn clean test -pl common -am -Dtest=none -DwildcardSuites=org.apache.celeborn.ConfigurationSuite

Also, maintainers need to enable the PR workflows for this PR. ping @SteNicholas @RexXiong @FMX PTAL

@Z1Wu
Copy link
Author

Z1Wu commented Oct 29, 2024

@Z1Wu You need to update the documentation as well using

UPDATE=1 build/mvn clean test -pl common -am -Dtest=none -DwildcardSuites=org.apache.celeborn.ConfigurationSuite

Also, maintainers need to enable the PR workflows for this PR. ping @SteNicholas @RexXiong @FMX PTAL

updated, thanks for your review.

@Z1Wu Z1Wu reopened this Oct 31, 2024
@@ -57,7 +57,7 @@ class QuotaManager(celebornConf: CelebornConf, configService: ConfigService) ext
userIdentifier: UserIdentifier,
value: Long,
quota: Quota): (Boolean, String) = {
val exceed = (quota.diskBytesWritten > 0 && value >= quota.diskBytesWritten)
val exceed = (quota.diskBytesWritten >= 0 && value >= quota.diskBytesWritten)
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It seems that if the value is negative, it indicates that the quota is unlimited, which feels a bit counterintuitive. For numbers less than or equal to 0, it seems better to directly determine them as having no quota.
cc @leixm @AngersZhuuuu

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants