database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: [fix](auth)Ignore replay edit log error of auth #49348 (#49787)

Browse Source 
Cherry-picked from #49348

Co-authored-by: zhangdong <zhangdong@selectdb.com>
This commit is contained in:
github-actions[bot]
2025-04-04 20:44:54 +08:00
committed by GitHub
parent 672829096e
commit 15662c06e6
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
fe/fe-core/src/main/java/org/apache/doris/mysql/privilege/Auth.java
View File

@ -511,8 +511,12 @@ public class Auth implements Writable {
dropUserInternal(stmt.getUserIdentity(), stmt.isSetIfExists(), false);
}
public void replayDropUser(UserIdentity userIdent) throws DdlException {
dropUserInternal(userIdent, false, true);
public void replayDropUser(UserIdentity userIdent) {
try {
dropUserInternal(userIdent, false, true);
} catch (DdlException e) {
LOG.error("should not happen", e);
}
}
private void dropUserInternal(UserIdentity userIdent, boolean ignoreIfNonExists, boolean isReplay)
@ -1026,8 +1030,12 @@ public class Auth implements Writable {
updateUserPropertyInternal(stmt.getUser(), properties, false /* is replay */);
}
public void replayUpdateUserProperty(UserPropertyInfo propInfo) throws UserException {
updateUserPropertyInternal(propInfo.getUser(), propInfo.getProperties(), true /* is replay */);
public void replayUpdateUserProperty(UserPropertyInfo propInfo) {
try {
updateUserPropertyInternal(propInfo.getUser(), propInfo.getProperties(), true /* is replay */);
} catch (UserException e) {
LOG.error("should not happened", e);
}
}
public void updateUserPropertyInternal(String user, List<Pair<String, String>> properties, boolean isReplay)