[enhancement](memory) Support try catch bad alloc (#14135)

2022-11-13 11:22:56 +08:00
parent 7682c08af0
commit dd11d5c0a5
33 changed files with 254 additions and 197 deletions
--- a/be/src/vec/exec/vaggregation_node.cpp
+++ b/be/src/vec/exec/vaggregation_node.cpp
@ -1054,7 +1054,7 @@ Status AggregationNode::_pre_agg_with_serialized_key(doris::vectorized::Block* i
            _agg_data._aggregated_method_variant);

    if (!ret_flag) {
-        _emplace_into_hash_table(_places.data(), key_columns, rows);
+        RETURN_IF_CATCH_BAD_ALLOC(_emplace_into_hash_table(_places.data(), key_columns, rows));

        for (int i = 0; i < _aggregate_evaluators.size(); ++i) {
            _aggregate_evaluators[i]->execute_batch_add(in_block, _offsets_of_aggregate_states[i],