This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 5c91fa943c9 [fix](coordinator) Fix NPE in updateLoadCounters during
reportExecStatus for non-Load queries (#61467)
5c91fa943c9 is described below
commit 5c91fa943c9bb64be407e835844ba18751381650
Author: Mingyu Chen (Rayner) <[email protected]>
AuthorDate: Wed Mar 25 18:56:05 2026 -0700
[fix](coordinator) Fix NPE in updateLoadCounters during reportExecStatus
for non-Load queries (#61467)
### What problem does this PR solve?
loadCounters and deltaUrls are only initialized in the Load (data sink)
path, but BE may report these fields even for external table SELECT
queries because num_finished_range > 0 triggers load_counters to be set
on BE side. Added null guards to prevent NPE when processing status
reports for non-Load queries.
---
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
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 f0705f8e195..dbce9b17256 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
@@ -2478,10 +2478,10 @@ public class Coordinator implements CoordInterface {
updateStatus(status);
}
}
- if (params.isSetDeltaUrls()) {
+ if (params.isSetDeltaUrls() && deltaUrls != null) {
updateDeltas(params.getDeltaUrls());
}
- if (params.isSetLoadCounters()) {
+ if (params.isSetLoadCounters() && loadCounters != null) {
updateLoadCounters(params.getLoadCounters());
}
if (params.isSetTrackingUrl()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
