This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new e84a55488e4 branch-3.0: [Fix](agg) Remove useless DCHECK for streaming
agg node #47842 (#48258)
e84a55488e4 is described below
commit e84a55488e4994f50616e3ad862cb76e4f2df897
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Feb 24 21:55:08 2025 +0800
branch-3.0: [Fix](agg) Remove useless DCHECK for streaming agg node #47842
(#48258)
Cherry-picked from #47842
Co-authored-by: zclllyybb <zhaochan...@selectdb.com>
---
be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp | 1 -
1 file changed, 1 deletion(-)
diff --git a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp
b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp
index 2f4a046003f..5d5ee62d487 100644
--- a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp
+++ b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.cpp
@@ -340,7 +340,6 @@
DistinctStreamingAggOperatorX::DistinctStreamingAggOperatorX(ObjectPool* pool, i
_is_streaming_preagg = tnode.agg_node.use_streaming_preaggregation;
if (_is_streaming_preagg) {
DCHECK(!tnode.agg_node.grouping_exprs.empty()) << "Streaming
preaggs do grouping";
- DCHECK(_limit == -1) << "Preaggs have no limits";
}
} else {
_is_streaming_preagg = false;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
