This is an automated email from the ASF dual-hosted git repository. dataroaring pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 375c0c62181d3eb98653fb595744807a29a73084 Author: hui lai <[email protected]> AuthorDate: Fri Sep 20 15:23:25 2024 +0800 [improve](multi table) allow auto resume if plan load fails (#40991) If plan fails, multi table load would not auto resume: ``` ReasonOfStateChanged: ErrorReason{code=errCode = 105, msg='failed to get stream load plan, errCode = 2, detailMessage = txn does not exist: 2998667899272192'} ``` In cloud mode, job will be unstable under deterioration of network conditions. --- .../src/main/java/org/apache/doris/service/FrontendServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java index 2d65001cbb5..5190728ea4b 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java @@ -2103,7 +2103,7 @@ public class FrontendServiceImpl implements FrontendService.Iface { try { RoutineLoadJob routineLoadJob = Env.getCurrentEnv().getRoutineLoadManager() .getRoutineLoadJobByMultiLoadTaskTxnId(request.getTxnId()); - routineLoadJob.updateState(JobState.PAUSED, new ErrorReason(InternalErrorCode.CANNOT_RESUME_ERR, + routineLoadJob.updateState(JobState.PAUSED, new ErrorReason(InternalErrorCode.INTERNAL_ERR, "failed to get stream load plan, " + exception.getMessage()), false); } catch (Throwable e) { LOG.warn("catch update routine load job error.", e); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
