diff --git a/springql-core/src/stream_engine/autonomous_executor/task/pump_task/pump_subtask/query_subtask/projection_subtask.rs b/springql-core/src/stream_engine/autonomous_executor/task/pump_task/pump_subtask/query_subtask/projection_subtask.rs
index 2b838ff8..0f2d3680 100644
--- a/springql-core/src/stream_engine/autonomous_executor/task/pump_task/pump_subtask/query_subtask/projection_subtask.rs
+++ b/springql-core/src/stream_engine/autonomous_executor/task/pump_task/pump_subtask/query_subtask/projection_subtask.rs
@@ -45,15 +45,15 @@ impl ProjectionSubtask {
             .exprs
             .iter()
             .map(|label| {
-                match label {
+                let value = match label {
                     ExprLabel::Value(group_by_value_label) => {
                         aggregated_and_grouping_values.get_group_by_value(group_by_value_label)
                     }
                     ExprLabel::Aggr(aggr_label) => {
                         aggregated_and_grouping_values.get_aggregated_value(aggr_label)
                     }
-                }
-                .cloned()
+                }?;
+                Ok(value.clone())
             })
             .collect::<Result<Vec<_>>>()?;