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 c100d62dc33 [fix](routine load) do not cancel job if not found
transaction (#39514)
c100d62dc33 is described below
commit c100d62dc33c09270a55ac7ac057399972f4750b
Author: hui lai <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
