This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5d9a3cc351d [improvement](cloud)Not allowed to operate internal_schema
database (#31278)
5d9a3cc351d is described below
commit 5d9a3cc351dfc6a2c17f26411f3708406f17e389
Author: zhangdong <[email protected]>
AuthorDate: Mon Feb 26 17:57:27 2024 +0800
[improvement](cloud)Not allowed to operate internal_schema database (#31278)
Inherited from： #29790
---
.../apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
index 258d1b54050..9059eeb7453 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
@@ -49,12 +49,14 @@ import org.apache.doris.common.MetaNotFoundException;
import org.apache.doris.common.QuotaExceedException;
import org.apache.doris.common.UserException;
import org.apache.doris.common.util.DebugUtil;
+import org.apache.doris.common.util.InternalDatabaseUtil;
import org.apache.doris.load.loadv2.LoadJobFinalOperation;
import org.apache.doris.load.routineload.RLTaskTxnCommitAttachment;
import org.apache.doris.metric.MetricRepo;
import org.apache.doris.persist.BatchRemoveTransactionsOperation;
import org.apache.doris.persist.BatchRemoveTransactionsOperationV2;
import org.apache.doris.persist.EditLog;
+import org.apache.doris.qe.ConnectContext;
import org.apache.doris.rpc.RpcException;
import org.apache.doris.thrift.TStatus;
import org.apache.doris.thrift.TUniqueId;
@@ -134,6 +136,11 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
throw new AnalysisException("disable_load_job is set to true, all
load jobs are prevented");
}
+ Database db =
Env.getCurrentInternalCatalog().getDbOrMetaException(dbId);
+ if (!coordinator.isFromInternal) {
+ InternalDatabaseUtil.checkDatabase(db.getFullName(),
ConnectContext.get());
+ }
+
switch (sourceType) {
case BACKEND_STREAMING:
checkValidTimeoutSecond(timeoutSecond,
Config.max_stream_load_timeout_second,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
