This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit d65f137a26953e32d88123b90920c99c2786a4e2 Author: Stalary <[email protected]> AuthorDate: Tue May 16 08:54:06 2023 +0800 [fix](row-policy) row policy supports external catalog (#19570) Row policy support external catalog --- fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java index c0b3a14ae6..9aa9162ff5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java @@ -21,7 +21,7 @@ package org.apache.doris.analysis; import org.apache.doris.catalog.Column; -import org.apache.doris.catalog.Database; +import org.apache.doris.catalog.DatabaseIf; import org.apache.doris.catalog.Env; import org.apache.doris.catalog.ScalarType; import org.apache.doris.catalog.TableIf; @@ -1308,7 +1308,8 @@ public class StmtRewriter { if (dbName == null) { dbName = analyzer.getDefaultDb(); } - Database db = currentEnv.getInternalCatalog().getDbOrAnalysisException(dbName); + DatabaseIf db = currentEnv.getCatalogMgr().getCatalogOrAnalysisException(tableRef.getName().getCtl()) + .getDbOrAnalysisException(dbName); long dbId = db.getId(); long tableId = table.getId(); RowPolicy matchPolicy = currentEnv.getPolicyMgr().getMatchTablePolicy(dbId, tableId, user); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
