database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](insert-into) fix insert into lose data (#29802)

Browse Source
This commit is contained in:
HHoflittlefish777
2024-01-10 21:51:05 +08:00
committed by yiguolei
parent 01a91a482e
commit 223e466514
1 changed files with 15 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -2520,7 +2520,14 @@ public class Coordinator implements CoordInterface {
params.getBackendId(), status.getErrorMsg());
updateStatus(status, params.getFragmentInstanceId());
}
if (ctx.fragmentInstancesMap.get(params.fragment_instance_id).getIsDone()) {
// params.isDone() should be promised.
// There are some periodic reports during the load process,
// and the reports from the intermediate process may be concurrent with the last report.
// The last report causes the counter to decrease to zero,
// but it is possible that the report without commit-info triggered the commit operation,
// resulting in the data not being published.
if (ctx.fragmentInstancesMap.get(params.fragment_instance_id).getIsDone() && params.isDone()) {
if (params.isSetDeltaUrls()) {
updateDeltas(params.getDeltaUrls());
}
@ -2585,7 +2592,13 @@ public class Coordinator implements CoordInterface {
}
}
if (execState.done) {
// params.isDone() should be promised.
// There are some periodic reports during the load process,
// and the reports from the intermediate process may be concurrent with the last report.
// The last report causes the counter to decrease to zero,
// but it is possible that the report without commit-info triggered the commit operation,
// resulting in the data not being published.
if (execState.done && params.isDone()) {
if (params.isSetDeltaUrls()) {
updateDeltas(params.getDeltaUrls());
}