This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 89ef5c062b1 [fix](routine load) do not cancel job if not found
transaction (#39514)
89ef5c062b1 is described below
commit 89ef5c062b1900e40939e6940e8afe4a3bcce57f
Author: hui lai <1353307...@qq.com>
AuthorDate: Wed Aug 21 20:31:05 2024 +0800
[fix](routine load) do not cancel job if not found transaction (#39514)
If do not find transaction when planning for the routine load task, the
routine load job will be canceled. In cloud mode, it may RPC timeout.
Meanwhile, it should not cancel the job if the transaction cannot be
found, as the job can still be rescheduled.
---
.../src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
index 9ecd0b78787..5ca291aa8d7 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java
@@ -999,7 +999,7 @@ public abstract class RoutineLoadJob
// add table indexes to transaction state
TransactionState txnState =
Env.getCurrentGlobalTransactionMgr().getTransactionState(db.getId(), txnId);
if (txnState == null) {
- throw new MetaNotFoundException("txn does not exist: " +
txnId);
+ throw new UserException("txn does not exist: " + txnId);
}
txnState.addTableIndexes(planner.getDestTable());
if (isPartialUpdate) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
