This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new a472ed3c69e [fix](stream load) do not throw exception but skip record
when can not find database (#39360) (#39531)
a472ed3c69e is described below
commit a472ed3c69e7bf1af1df743e52059e972dc10042
Author: hui lai <[email protected]>
AuthorDate: Mon Aug 19 21:19:55 2024 +0800
[fix](stream load) do not throw exception but skip record when can not find
database (#39360) (#39531)
pick (#39360)
When fetch stream load record from BE node, if can not find database,
StreamLoadRecordMgr will throw exception and the remaining records will
not be recorded in memory.
For example: Ten stream load records were pulled, and the database
associated with the stream load of the first record was deleted by the
user. Therefore, the pull will end, resulting in the remaining nine
records not being consumed recorded in memory.
This pr do not throw exception but skip record when can not find
database to solve this problem.
---
.../src/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 5b58425dfa0..7cdd69da2dc 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.catalog.Env;
import org.apache.doris.cluster.ClusterNamespace;
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;
@@ -309,7 +308,8 @@ public class StreamLoadRecordMgr extends MasterDaemon {
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()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
