-
Notifications
You must be signed in to change notification settings - Fork 455
[server] Support AddServerTag and RemoveServerTag #1400
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
base: main
Are you sure you want to change the base?
Conversation
fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java
Show resolved
Hide resolved
2368e6a to
d24c6d7
Compare
d88c76c to
434a4f4
Compare
1889c56 to
d7a7352
Compare
17d0124 to
170a35e
Compare
| @Override | ||
| public CompletableFuture<AddServerTagResponse> addServerTag(AddServerTagRequest request) { | ||
| throw new UnsupportedOperationException("Support soon!"); | ||
| CompletableFuture<AddServerTagResponse> response = new CompletableFuture<>(); |
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.
Missing permission control?
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.
Maybe we can support this in a separate PR later. Additionally, I noticed that the RPC listOffsets also lacks permission control—we could address this together in the same issue.
fluss-server/src/main/java/org/apache/fluss/server/coordinator/CoordinatorService.java
Show resolved
Hide resolved
170a35e to
7f45297
Compare
7f45297 to
5255b80
Compare
Purpose
Linked issue: close #1388
This pr is aims to support AddServerTag and RemoveServerTag.
Brief change log
Tests
API and Format
Documentation