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

…atus fail (apache#32638) (apache#37444) pick apache#32638 Co-authored-by: HHoflittlefish777 <77738092+HHoflittlefish777@users.noreply.github.com>
dataroaring · Jul 9, 2024 · f96de8e · f96de8e
1 parent f030c43
commit f96de8e
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
@@ -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."