This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 0fda7a769aa branch-4.0: [fix](coordinator) fix "PStatus: Finished"
#57985 (#57998)
0fda7a769aa is described below
commit 0fda7a769aace8faa672b9cffbad5f2e05eb2d35
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Nov 14 10:24:02 2025 +0800
branch-4.0: [fix](coordinator) fix "PStatus: Finished" #57985 (#57998)
Cherry-picked from #57985
Co-authored-by: 924060929 <[email protected]>
---
.../src/main/java/org/apache/doris/qe/AbstractJobProcessor.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/qe/AbstractJobProcessor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/AbstractJobProcessor.java
index 218749462fe..3970acfd5fe 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/AbstractJobProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/AbstractJobProcessor.java
@@ -24,6 +24,8 @@ import org.apache.doris.qe.runtime.MultiFragmentsPipelineTask;
import org.apache.doris.qe.runtime.PipelineExecutionTask;
import org.apache.doris.qe.runtime.SingleFragmentPipelineTask;
import org.apache.doris.thrift.TReportExecStatusParams;
+import org.apache.doris.thrift.TStatus;
+import org.apache.doris.thrift.TStatusCode;
import org.apache.doris.thrift.TUniqueId;
import com.google.common.base.Preconditions;
@@ -82,6 +84,9 @@ public abstract class AbstractJobProcessor implements
JobProcessor {
@Override
public final void updateFragmentExecStatus(TReportExecStatusParams params)
{
+ if (params.status.status_code == TStatusCode.FINISHED) {
+ params.status = new TStatus(TStatusCode.OK);
+ }
SingleFragmentPipelineTask fragmentTask =
backendFragmentTasks.get().get(
new BackendFragmentId(params.getBackendId(),
params.getFragmentId()));
if (fragmentTask == null) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
