-
Notifications
You must be signed in to change notification settings - Fork 70
[Feature] Add AccessManager #61
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
Merged
Merged
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
jerqi
reviewed
Jan 5, 2022
17c077d to
9c31a9c
Compare
jerqi
reviewed
Jan 5, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
9c31a9c to
a25abc4
Compare
colinmjj
reviewed
Jan 5, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessChecker.java
Outdated
Show resolved
Hide resolved
frankliee
reviewed
Jan 5, 2022
a25abc4 to
47db5f1
Compare
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessCandidatesChecker.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessCandidatesChecker.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessChecker.java
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/ClusterManager.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 7, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/ServerNode.java
Outdated
Show resolved
Hide resolved
colinmjj
reviewed
Jan 10, 2022
common/src/test/java/com/tencent/rss/common/util/RssUtilsTest.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessCandidatesChecker.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessChecker.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorGrpcService.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorGrpcService.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorServer.java
Outdated
Show resolved
Hide resolved
frankliee
reviewed
Jan 10, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessClusterLoadChecker.java
Show resolved
Hide resolved
92e5811 to
a7f7a4d
Compare
5e76a2f to
1bc3bf2
Compare
2b09a38 to
8b0c874
Compare
83b0fc8 to
4180592
Compare
colinmjj
reviewed
Jan 12, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessManager.java
Show resolved
Hide resolved
f20ca88 to
65818c1
Compare
colinmjj
reviewed
Jan 13, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessCandidatesChecker.java
Outdated
Show resolved
Hide resolved
coordinator/src/main/java/com/tencent/rss/coordinator/AccessCandidatesChecker.java
Show resolved
Hide resolved
65818c1 to
5e8b0dd
Compare
colinmjj
previously approved these changes
Jan 13, 2022
Collaborator
colinmjj
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
5e8b0dd to
8e76d17
Compare
colinmjj
previously approved these changes
Jan 13, 2022
8e76d17 to
5dca114
Compare
jerqi
reviewed
Jan 13, 2022
common/src/main/java/com/tencent/rss/common/config/ConfigUtils.java
Outdated
Show resolved
Hide resolved
f0c70cf to
2d67fec
Compare
jerqi
reviewed
Jan 14, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessChecker.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 14, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/AccessClusterLoadChecker.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 14, 2022
coordinator/src/main/java/com/tencent/rss/coordinator/CoordinatorConf.java
Outdated
Show resolved
Hide resolved
jerqi
reviewed
Jan 14, 2022
2d67fec to
562fed1
Compare
Collaborator
Author
|
@colinmjj @jerqi @frankliee all comments resolved |
jerqi
approved these changes
Jan 17, 2022
duanmeng
added a commit
that referenced
this pull request
Jan 26, 2022
# What changes were proposed in this pull request? Add a delegation shuffle manager choose the actual shuffle manager (sort or rss) # Why are the changes needed? This pr is related to #61, which add access client. # Does this PR introduce any user-facing change? Yes, client need to config spark.shuffle.manager explicitly and add the following config , spark.rss.accessInfoKey it specifies which is the config key of the accessInfo and then add the config duration submition. # How was this patch tested? UT and system test
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
What changes were proposed in this pull request?
Add access manager to handle cron task access requests and add checkers to check the candidate list and cluster load respectively.
Why are the changes needed?
We need to add candidates checking and control of the access when the cluster load is high.
Does this PR introduce any user-facing change?
Yes, need to update the client to enable this feature.
How was this patch tested?
UT and system test.