This is an automated email from the ASF dual-hosted git repository.
dataroaring 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 a5b03d3f792 [fix](groupcommit) remove NDEBUG for groupcommit's memory
tracker (#56577)
a5b03d3f792 is described below
commit a5b03d3f7923376ba3b0976b4d4fd138a8674ce2
Author: Yongqiang YANG <[email protected]>
AuthorDate: Tue Oct 7 19:55:52 2025 +0800
[fix](groupcommit) remove NDEBUG for groupcommit's memory tracker (#56577)
Co-authored-by: Yongqiang YANG <[email protected]>
---
be/src/pipeline/pipeline_fragment_context.cpp | 4 ----
1 file changed, 4 deletions(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index ec048d0db51..d59bffe4ad9 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -1040,10 +1040,8 @@ Status
PipelineFragmentContext::_create_data_sink(ObjectPool* pool, const TDataS
}
case TDataSinkType::GROUP_COMMIT_BLOCK_SINK: {
DCHECK(thrift_sink.__isset.olap_table_sink);
-#ifndef NDEBUG
DCHECK(state->get_query_ctx() != nullptr);
state->get_query_ctx()->query_mem_tracker()->is_group_commit_load =
true;
-#endif
_sink =
std::make_shared<GroupCommitBlockSinkOperatorX>(next_sink_operator_id(),
row_desc,
output_exprs);
break;
@@ -1193,10 +1191,8 @@ Status
PipelineFragmentContext::_create_operator(ObjectPool* pool, const TPlanNo
break;
}
case TPlanNodeType::GROUP_COMMIT_SCAN_NODE: {
-#ifndef NDEBUG
DCHECK(_query_ctx != nullptr);
_query_ctx->query_mem_tracker()->is_group_commit_load = true;
-#endif
op = std::make_shared<GroupCommitOperatorX>(pool, tnode,
next_operator_id(), descs,
_num_instances);
RETURN_IF_ERROR(cur_pipe->add_operator(op, _parallel_instances));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
