This is an automated email from the ASF dual-hosted git repository.
liaoxin 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 e2c92806534 [fix](stream load) do not throw exception but skip record
when can not find database (#39360)
e2c92806534 is described below
commit e2c928065347e6d55da4ddef2703a1328c3281a3
Author: hui lai <[email protected]>
AuthorDate: Thu Aug 15 16:19:59 2024 +0800
[fix](stream load) do not throw exception but skip record when can not find
database (#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 1e1dc192cee..020b38158d1 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.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 @@ 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]
