This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 12e6648903a [fix](auth)fix fe can not restart when replay create row
policy log #37342 (#37549)
12e6648903a is described below
commit 12e6648903ae7747e20e31441f2be86ca40649e3
Author: zhangdong <493738...@qq.com>
AuthorDate: Tue Jul 9 21:06:42 2024 +0800
[fix](auth)fix fe can not restart when replay create row policy log #37342
(#37549)
---
fe/fe-core/src/main/java/org/apache/doris/policy/RowPolicy.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/policy/RowPolicy.java
b/fe/fe-core/src/main/java/org/apache/doris/policy/RowPolicy.java
index ce16de06770..d7c2cfa11d0 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/policy/RowPolicy.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/policy/RowPolicy.java
@@ -147,7 +147,10 @@ public class RowPolicy extends Policy {
CreatePolicyStmt stmt = (CreatePolicyStmt)
SqlParserUtils.getFirstStmt(parser);
wherePredicate = stmt.getWherePredicate();
} catch (Exception e) {
- throw new IOException("table policy parse originStmt error", e);
+ String errorMsg = String.format("table policy parse originStmt
error, originStmt: %s.",
+ originStmt);
+ // Only print logs to avoid cluster failure to start
+ LOG.warn(errorMsg, e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
