This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.1 by this push:
new 31670b8c632 branch-4.1: [fix](be) Fix DCHECK in
LocalExchangeSharedState::sub_total_mem_usage #63742 (#64014)
31670b8c632 is described below
commit 31670b8c6324d248413fd767f7f607168c9da77d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jun 3 11:44:22 2026 +0800
branch-4.1: [fix](be) Fix DCHECK in
LocalExchangeSharedState::sub_total_mem_usage #63742 (#64014)
Cherry-picked from #63742
Co-authored-by: TengJianPing <[email protected]>
---
be/src/exec/pipeline/dependency.h | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/be/src/exec/pipeline/dependency.h
b/be/src/exec/pipeline/dependency.h
index dec1d3aaeea..f7a90ea0c34 100644
--- a/be/src/exec/pipeline/dependency.h
+++ b/be/src/exec/pipeline/dependency.h
@@ -749,7 +749,8 @@ public:
void sub_total_mem_usage(size_t delta) {
auto prev_usage = mem_usage.fetch_sub(delta);
- DCHECK_GE(prev_usage - delta, 0) << "prev_usage: " << prev_usage << "
delta: " << delta;
+ DCHECK_GE(prev_usage, cast_set<int64_t>(delta))
+ << "prev_usage: " << prev_usage << " delta: " << delta;
if (cast_set<int64_t>(prev_usage - delta) <= _buffer_mem_limit) {
sink_deps.front()->set_ready();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
