fix(query): fix deserialize bug for aggregation

Author: sundy-li

src/query/functions-v2/src/aggregates/adaptors/aggregate_null_unary_adaptor.rs

@@ -182,9 +182,9 @@ impl<const NULLABLE_RESULT: bool> AggregateFunction for AggregateNullUnaryAdapto
 
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
         if NULLABLE_RESULT {
+            let flag = reader[reader.len() - 1];
             self.nested
                 .deserialize(place, &mut &reader[..reader.len() - 1])?;
-            let flag = reader[reader.len() - 1];
             self.set_flag(place, flag);
         } else {
             self.nested.deserialize(place, reader)?;

src/query/functions-v2/src/aggregates/adaptors/aggregate_null_variadic_adaptor.rs

@@ -184,9 +184,9 @@ impl<const NULLABLE_RESULT: bool> AggregateFunction
 
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
         if NULLABLE_RESULT {
+            let flag = reader[reader.len() - 1];
             self.nested
                 .deserialize(place, &mut &reader[..reader.len() - 1])?;
-            let flag = reader[reader.len() - 1];
             self.set_flag(place, flag);
         } else {
             self.nested.deserialize(place, reader)?;

src/query/functions-v2/src/aggregates/adaptors/aggregate_ornull_adaptor.rs

@@ -174,9 +174,9 @@ impl AggregateFunction for AggregateFunctionOrNullAdaptor {
 
     #[inline]
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
+        let flag = reader[reader.len() - 1];
         self.inner
             .deserialize(place, &mut &reader[..reader.len() - 1])?;
-        let flag = reader[reader.len() - 1];
         self.set_flag(place, flag);
         Ok(())
     }

src/query/functions/src/aggregates/adaptors/aggregate_null_unary_adaptor.rs

@@ -183,9 +183,9 @@ impl<const NULLABLE_RESULT: bool> AggregateFunction for AggregateNullUnaryAdapto
 
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
         if NULLABLE_RESULT {
+            let flag = reader[reader.len() - 1];
             self.nested
                 .deserialize(place, &mut &reader[..reader.len() - 1])?;
-            let flag = reader[reader.len() - 1];
             self.set_flag(place, flag);
         } else {
             self.nested.deserialize(place, reader)?;

src/query/functions/src/aggregates/adaptors/aggregate_null_variadic_adaptor.rs

@@ -198,9 +198,9 @@ impl<const NULLABLE_RESULT: bool> AggregateFunction
 
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
         if NULLABLE_RESULT {
+            let flag = reader[reader.len() - 1];
             self.nested
                 .deserialize(place, &mut &reader[..reader.len() - 1])?;
-            let flag = reader[reader.len() - 1];
             self.set_flag(place, flag);
         } else {
             self.nested.deserialize(place, reader)?;

src/query/functions/src/aggregates/adaptors/aggregate_ornull_adaptor.rs

@@ -178,9 +178,9 @@ impl AggregateFunction for AggregateFunctionOrNullAdaptor {
 
     #[inline]
     fn deserialize(&self, place: StateAddr, reader: &mut &[u8]) -> Result<()> {
+        let flag = reader[reader.len() - 1];
         self.inner
             .deserialize(place, &mut &reader[..reader.len() - 1])?;
-        let flag = reader[reader.len() - 1];
         self.set_flag(place, flag);
         Ok(())
     }