diff --git a/be/test/vec/aggregate_functions/vec_window_funnel_test.cpp b/be/test/vec/aggregate_functions/vec_window_funnel_test.cpp index f0c93c4beab028..96a08421a8d096 100644 --- a/be/test/vec/aggregate_functions/vec_window_funnel_test.cpp +++ b/be/test/vec/aggregate_functions/vec_window_funnel_test.cpp @@ -148,10 +148,15 @@ TEST_F(VWindowFunnelTest, testSerialize) { agg_function->add(place, column, i, nullptr); } + ColumnVector column_result; + agg_function->insert_result_into(place, column_result); + EXPECT_EQ(column_result.get_data()[0], 3); + ColumnString buf; VectorBufferWriter buf_writer(buf); agg_function->serialize(place, buf_writer); buf_writer.commit(); + agg_function->destroy(place); std::unique_ptr memory2(new char[agg_function->size_of_data()]); AggregateDataPtr place2 = memory2.get(); @@ -160,11 +165,6 @@ TEST_F(VWindowFunnelTest, testSerialize) { VectorBufferReader buf_reader(buf.get_data_at(0)); agg_function->deserialize(place2, buf_reader, nullptr); - ColumnVector column_result; - agg_function->insert_result_into(place, column_result); - EXPECT_EQ(column_result.get_data()[0], 3); - agg_function->destroy(place); - ColumnVector column_result2; agg_function->insert_result_into(place2, column_result2); EXPECT_EQ(column_result2.get_data()[0], 3);