From 8a6fc79797de660d4dd4e6db971e86f641eecbaa Mon Sep 17 00:00:00 2001 From: HHoflittlefish777 <77738092+HHoflittlefish777@users.noreply.github.com> Date: Fri, 22 Mar 2024 12:54:23 +0800 Subject: [PATCH] [fix](routine-load) avoid routine load pause for check transaction status fail (#32638) --- .../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 f9be2014e3..0f8341150f 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 @@ -1114,7 +1114,8 @@ public abstract class RoutineLoadJob extends AbstractTxnStateChangeCallback impl 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."