This is an automated email from the ASF dual-hosted git repository.
starocean999 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 2bed04229ae [fix](constraint) start failed if Catalog connect failed.
(#61299)
2bed04229ae is described below
commit 2bed04229ae7feebb59a86498acee1d63295e19d
Author: morrySnow <[email protected]>
AuthorDate: Fri Mar 13 15:01:01 2026 +0800
[fix](constraint) start failed if Catalog connect failed. (#61299)
Related PR: #61118
shoud only migrate InternalCatalog
---
fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
index 77c1187effe..789410a629c 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Env.java
@@ -92,7 +92,6 @@ import org.apache.doris.datasource.CatalogMgr;
import org.apache.doris.datasource.ExternalCatalog;
import org.apache.doris.datasource.ExternalMetaCacheMgr;
import org.apache.doris.datasource.ExternalMetaIdMgr;
-import org.apache.doris.datasource.ExternalTable;
import org.apache.doris.datasource.InternalCatalog;
import org.apache.doris.datasource.SplitSourceManager;
import org.apache.doris.datasource.es.EsExternalCatalog;
@@ -2912,6 +2911,9 @@ public class Env {
}
int migratedCount = 0;
for (CatalogIf catalog : catalogMgr.getCopyOfCatalog()) {
+ if (!(catalog instanceof InternalCatalog)) {
+ continue;
+ }
for (Object dbObj : catalog.getAllDbs()) {
DatabaseIf db = (DatabaseIf) dbObj;
for (Object tableObj : db.getTables()) {
@@ -2919,11 +2921,7 @@ public class Env {
try {
Map<String, Constraint> oldConstraints = null;
if (table instanceof Table) {
- oldConstraints = ((Table) table)
- .getTableAttributes().getConstraintsMap();
- } else if (table instanceof ExternalTable) {
- oldConstraints = ((ExternalTable) table)
- .getTableAttributes().getConstraintsMap();
+ oldConstraints = ((Table)
table).getTableAttributes().getConstraintsMap();
} else {
LOG.debug("Skipping constraint migration for "
+ "unsupported table type: {} ({})",
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
