From f96de8eae00a1678ef3542a9fc619a0018e2ffb3 Mon Sep 17 00:00:00 2001 From: hui lai <1353307710@qq.com> Date: Tue, 9 Jul 2024 10:09:56 +0800 Subject: [PATCH] [fix](routine-load) avoid routine load pause for check transaction status fail (#32638) (#37444) pick #32638 Co-authored-by: HHoflittlefish777 <77738092+HHoflittlefish777@users.noreply.github.com> --- .../java/org/apache/doris/load/routineload/RoutineLoadJob.java | 3 ++- 1 file changed, 2 insertions(+), 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 7723224e5a2426..58eff713b4530a 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 @@ -1085,7 +1085,8 @@ public void afterVisible(TransactionState txnState, boolean txnOperated) { return; } RoutineLoadTaskInfo routineLoadTaskInfo = routineLoadTaskInfoOptional.get(); - if (routineLoadTaskInfo.getTxnStatus() != TransactionStatus.COMMITTED) { + if (routineLoadTaskInfo.getTxnStatus() != TransactionStatus.COMMITTED + && routineLoadTaskInfo.getTxnStatus() != TransactionStatus.VISIBLE) { // TODO(cmy): Normally, this should not happen. But for safe reason, just pause the job String msg = String.format( "should not happen, we find that task %s is not COMMITTED when handling afterVisble."