This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 8a6fc79797de660d4dd4e6db971e86f641eecbaa Author: HHoflittlefish777 <[email protected]> AuthorDate: Fri Mar 22 12:54:23 2024 +0800 [fix](routine-load) avoid routine load pause for check transaction status fail (#32638) --- .../main/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 f9be2014e30..0f8341150fe 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." --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
