This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 6f30b96da09 [fix](cloud) fix add partition failed (#30532)
6f30b96da09 is described below
commit 6f30b96da09f73b290551c78d9055769dd7eaa09
Author: yujun <[email protected]>
AuthorDate: Tue Jan 30 09:49:12 2024 +0800
[fix](cloud) fix add partition failed (#30532)
---
fe/fe-core/src/main/java/org/apache/doris/alter/Alter.java | 8 ++------
.../org/apache/doris/cloud/datasource/CloudInternalCatalog.java | 2 +-
.../main/java/org/apache/doris/datasource/InternalCatalog.java | 2 +-
3 files changed, 4 insertions(+), 8 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/alter/Alter.java
b/fe/fe-core/src/main/java/org/apache/doris/alter/Alter.java
index 11ef9d90156..a5a12860d62 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/alter/Alter.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/alter/Alter.java
@@ -112,10 +112,7 @@ public class Alter {
// check db
String dbName = stmt.getDBName();
Database db =
Env.getCurrentInternalCatalog().getDbOrDdlException(dbName);
- // check cluster capacity
- Env.getCurrentSystemInfo().checkAvailableCapacity();
- // check db quota
- db.checkQuota();
+ Env.getCurrentInternalCatalog().checkAvailableCapacity(db);
OlapTable olapTable = (OlapTable)
db.getTableOrMetaException(tableName, TableType.OLAP);
((MaterializedViewHandler)
materializedViewHandler).processCreateMaterializedView(stmt, db, olapTable);
@@ -150,8 +147,7 @@ public class Alter {
// check cluster capacity and db quota, only need to check once.
if (currentAlterOps.needCheckCapacity()) {
- Env.getCurrentSystemInfo().checkAvailableCapacity();
- db.checkQuota();
+ Env.getCurrentInternalCatalog().checkAvailableCapacity(db);
}
olapTable.checkNormalStateForAlter();
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
index d7efdefe775..1a65faf5a94 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/datasource/CloudInternalCatalog.java
@@ -658,7 +658,7 @@ public class CloudInternalCatalog extends InternalCatalog {
// END DROP TABLE
@Override
- protected void checkAvailableCapacity(Database db) throws DdlException {
+ public void checkAvailableCapacity(Database db) throws DdlException {
}
private void sleepSeveralMs() {
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 7f1dd7a64e7..6876d088021 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -2022,7 +2022,7 @@ public class InternalCatalog implements
CatalogIf<Database> {
throws DdlException {
}
- protected void checkAvailableCapacity(Database db) throws DdlException {
+ public void checkAvailableCapacity(Database db) throws DdlException {
// check cluster capacity
Env.getCurrentSystemInfo().checkAvailableCapacity();
// check db quota
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
