[fix](routine-load) avoid routine load pause for check transaction st…

…atus fail (apache#32638)
CalvinKirs · Mar 22, 2024 · 7bb1d79 · 7bb1d79
1 parent 50e999d
commit 7bb1d79
Showing 1 changed file with 2 additions and 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
@@ -1166,7 +1166,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."