sollhui commented on code in PR #66105:
URL: https://github.com/apache/doris/pull/66105#discussion_r3701106327
##########
fe/fe-core/src/main/java/org/apache/doris/load/routineload/RoutineLoadJob.java:
##########
@@ -1353,6 +1353,15 @@ public void afterAborted(TransactionState txnState,
boolean txnOperated, String
}
// TODO(ml): use previous be id depend on change reason
}
+ if (txnStatusChangeReason !=
TransactionState.TxnStatusChangeReason.NO_PARTITIONS) {
+ String msg = "be " + taskBeId + " abort task,"
+ + " task id: " + routineLoadTaskInfo.getId()
+ + " job id: " + routineLoadTaskInfo.getJobId()
+ + " with reason: " + txnStatusChangeReasonString;
+ updateState(JobState.PAUSED,
Review Comment:
Superseded by 9cca71485fc. The replay-persistence changes and replay unit
test from 5dd9b659044 have been reverted. The net change from dcd6d23ae17 now
only removes the NO_PARTITIONS guard in afterAborted(), because
empty/all-unselected routine-load tasks commit successfully on the current path
since #7240. replayOnAborted() and the existing edit-log behavior are
unchanged, so this replay-equivalence review point is intentionally not claimed
as addressed by the new commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
