This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-1.2-lts by this push:
new 97775be474 [cherry-pick](udaf) fix java-udaf can't exectue add
function (#20663)
97775be474 is described below
commit 97775be47445692be39c60e54a9e2e18ce4b2fc6
Author: zhangstar333 <[email protected]>
AuthorDate: Sat Jun 10 22:53:23 2023 +0800
[cherry-pick](udaf) fix java-udaf can't exectue add function (#20663)
cherry-pick from master #20554
---
be/src/vec/aggregate_functions/aggregate_function_java_udaf.h | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/be/src/vec/aggregate_functions/aggregate_function_java_udaf.h
b/be/src/vec/aggregate_functions/aggregate_function_java_udaf.h
index 1abf2d5208..2ea485bd7a 100644
--- a/be/src/vec/aggregate_functions/aggregate_function_java_udaf.h
+++ b/be/src/vec/aggregate_functions/aggregate_function_java_udaf.h
@@ -341,10 +341,12 @@ public:
DataTypePtr get_return_type() const override { return _return_type; }
- void add(AggregateDataPtr __restrict /*place*/, const IColumn**
/*columns*/, size_t /*row_num*/,
+ void add(AggregateDataPtr __restrict place, const IColumn** columns,
size_t row_num,
Arena*) const override {
- LOG(WARNING) << " shouldn't going add function, there maybe some error
about function "
- << _fn.name.function_name;
+ int64_t places_address[1];
+ places_address[0] = reinterpret_cast<int64_t>(place);
+ this->data(_exec_place)
+ .add(places_address, true, columns, row_num, row_num + 1,
argument_types);
}
void add_batch(size_t batch_size, AggregateDataPtr* places, size_t
place_offset,
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
