From 9f76e4f220559262455f27f4017392eb52428859 Mon Sep 17 00:00:00 2001
From: laihui <1353307710@qq.com>
Date: Sat, 17 Aug 2024 08:59:20 +0800
Subject: [PATCH] do not cancel job if not found transaction

---
 .../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 a25cd99985892e..57294814a1ee31 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 TPipelineFragmentParams plan(TUniqueId loadId, long txnId) throws UserExc
             // 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) {