You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/05/06 09:20:48 UTC
[incubator-doris] 09/11: [fix](function) handle merge in window_funnel_init and add test (#9338)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
commit 20c3744d683fe000a032b317919642d426149f53
Author: dataroaring <98...@users.noreply.github.com>
AuthorDate: Tue May 3 22:37:06 2022 +0800
[fix](function) handle merge in window_funnel_init and add test (#9338)
---
be/src/exprs/aggregate_functions.cpp | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/be/src/exprs/aggregate_functions.cpp b/be/src/exprs/aggregate_functions.cpp
index 52883d04d9..506a87a821 100644
--- a/be/src/exprs/aggregate_functions.cpp
+++ b/be/src/exprs/aggregate_functions.cpp
@@ -2499,9 +2499,10 @@ void AggregateFunctions::window_funnel_init(FunctionContext* ctx, StringVal* dst
WindowFunnelState* state = new WindowFunnelState();
dst->ptr = (uint8_t*)state;
// constant args at index 0 and 1
- DCHECK(ctx->is_arg_constant(0));
- BigIntVal* window = reinterpret_cast<BigIntVal*>(ctx->get_constant_arg(0));
- state->window = window->val;
+ if (ctx->is_arg_constant(0)) {
+ BigIntVal* window = reinterpret_cast<BigIntVal*>(ctx->get_constant_arg(0));
+ state->window = window->val;
+ }
// TODO handle mode in the future
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org