pipeline code

zhangstar333 · Jul 24, 2024 · 4fcb761 · 4fcb761
1 parent 15d9adc
commit 4fcb761
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/be/src/vec/exec/vanalytic_eval_node.cpp b/be/src/vec/exec/vanalytic_eval_node.cpp
@@ -691,7 +691,8 @@ void VAnalyticEvalNode::_execute_for_win_func(int64_t partition_start, int64_t p
         }
         _agg_functions[i]->function()->add_range_single_place(
                 partition_start, partition_end, frame_start, frame_end,
-                _fn_place_ptr + _offsets_of_aggregate_states[i], _agg_columns.data(), nullptr);
+                _fn_place_ptr + _offsets_of_aggregate_states[i], _agg_columns.data(),
+                _agg_arena_pool.get());
     }
 
     // If the end is not greater than the start, the current window should be empty.