From 95545681f927abaa44c383f9ab405e4019dea991 Mon Sep 17 00:00:00 2001 From: laihui <1353307710@qq.com> Date: Wed, 14 Aug 2024 22:38:12 +0800 Subject: [PATCH] do not throw exception but skip record when can not find database --- .../main/java/org/apache/doris/load/StreamLoadRecordMgr.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java index 1e1dc192ceeac1..020b38158d1855 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java +++ b/fe/fe-core/src/main/java/org/apache/doris/load/StreamLoadRecordMgr.java @@ -23,7 +23,6 @@ import org.apache.doris.common.AnalysisException; import org.apache.doris.common.ClientPool; import org.apache.doris.common.Config; -import org.apache.doris.common.UserException; import org.apache.doris.common.io.Text; import org.apache.doris.common.io.Writable; import org.apache.doris.common.util.MasterDaemon; @@ -324,7 +323,8 @@ protected void runAfterCatalogReady() { if (Strings.isNullOrEmpty(streamLoadItem.getCluster())) { dbName = streamLoadItem.getDb(); } - throw new UserException("unknown database, database=" + dbName); + LOG.warn("unknown database, database=" + dbName); + continue; } long dbId = db.getId(); Env.getCurrentEnv().getStreamLoadRecordMgr()