This is an automated email from the ASF dual-hosted git repository.
kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new d7548fc0771 fix: restore load job progress before retry load task
(#26802)
d7548fc0771 is described below
commit d7548fc0771c5b5c1560b561475ced468d0a8b7b
Author: TsukiokaKogane <[email protected]>
AuthorDate: Sat Nov 11 18:13:23 2023 +0800
fix: restore load job progress before retry load task (#26802)
Co-authored-by: chenboyang.922 <[email protected]>
---
fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
index a6c5b012e07..c1b2417bf82 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BulkLoadJob.java
@@ -218,6 +218,8 @@ public abstract class BulkLoadJob extends LoadJob {
idToTasks.remove(loadTask.getSignature());
if (loadTask instanceof LoadLoadingTask) {
loadStatistic.removeLoad(((LoadLoadingTask)
loadTask).getLoadId());
+ // restore load progress
+
Env.getCurrentProgressManager().registerProgressSimple(String.valueOf(id));
}
loadTask.updateRetryInfo();
idToTasks.put(loadTask.getSignature(), loadTask);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
