-
Notifications
You must be signed in to change notification settings - Fork 150
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
[#2261]: feat(Coordinator): Introduce banned id manager and checker #2255
base: master
Are you sure you want to change the base?
Conversation
031dac0
to
572c564
Compare
572c564
to
c72a5c9
Compare
Thanks for proposing this, I think I will review this in next days. |
You would better create an issue for a feature or a bug. |
@jerqi Thank you for remind me this, I created an issue mark it as a feature. |
@zuston Would you like to take a look this week? Thank you. |
Sorry for the late reply, I'm struggle with the busy work. I will review this tonight. |
I do a quick review about this issue, and I hope I have gotten your motivation that you want to remote control the spark app to determinze whether to use uniffle or sort based shuffle manager. If so, I think the current code base have provided these ability to implement custom plugin to control this. For the client side, you could implement the custom shuffle manager to extend the DelegationShuffleManager to inject the extra info into the access request's For the coordinator side, you also could implement custom checker to retrieve above extra properties to control app pass or not. |
What changes were proposed in this pull request?
Introduce banned id manager and checker
Why are the changes needed?
Provide a common way to banned an app to fallback to SORT shuffle manager.
The app id can be extracted from a specific spark conf.
Fix: #2261
Does this PR introduce any user-facing change?
How was this patch tested?
New added UT.