From 38aecb72c9e29ef7e414e34fa36e8e5734669936 Mon Sep 17 00:00:00 2001 From: BiteTheDDDDt Date: Mon, 1 Jul 2024 20:59:00 +0800 Subject: [PATCH] do not throw eception when DataTypeAggState meet old be exec vertion --- be/src/vec/data_types/data_type_agg_state.h | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/be/src/vec/data_types/data_type_agg_state.h b/be/src/vec/data_types/data_type_agg_state.h index 6b4fdc64562fb8..96b147c8e96f33 100644 --- a/be/src/vec/data_types/data_type_agg_state.h +++ b/be/src/vec/data_types/data_type_agg_state.h @@ -43,11 +43,13 @@ class DataTypeAggState : public DataTypeString { _be_exec_version(be_exec_version) { _agg_function = AggregateFunctionSimpleFactory::instance().get(_function_name, _sub_types, _result_is_nullable); - if (_agg_function == nullptr || - !BeExecVersionManager::check_be_exec_version(be_exec_version)) { + if (_agg_function == nullptr) { throw Exception(ErrorCode::INVALID_ARGUMENT, "DataTypeAggState function get failed, type={}", do_get_name()); } + if (!BeExecVersionManager::check_be_exec_version(be_exec_version)) { + LOG(WARNING) << "meet old agg-state, be_exec_version=" << be_exec_version; + } _agg_function->set_version(be_exec_version); _agg_serialized_type = _agg_function->get_serialized_type(); }