From 415f1053a4cb14cdbf34ace021a14c1b2ac0aa50 Mon Sep 17 00:00:00 2001 From: Mingyu Chen Date: Mon, 19 Jun 2023 18:13:43 +0800 Subject: [PATCH] [minor](progress) do not update progress if job id is not set (#20949) --- fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index 75489d8246..23bb0d4ba5 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -2216,7 +2216,7 @@ public class Coordinator { } } - if (params.isSetLoadedRows()) { + if (params.isSetLoadedRows() && jobId != -1) { Env.getCurrentEnv().getLoadManager().updateJobProgress( jobId, params.getBackendId(), params.getQueryId(), params.getFragmentInstanceId(), params.getLoadedRows(), params.getLoadedBytes(), params.isDone());