diff --git a/hybridse/src/vm/transform.cc b/hybridse/src/vm/transform.cc index d217d066cc3..08b4c15201b 100644 --- a/hybridse/src/vm/transform.cc +++ b/hybridse/src/vm/transform.cc @@ -213,7 +213,7 @@ Status BatchModeTransformer::InitFnInfo(PhysicalOpNode* node, } case kAggregation: { // Code generation for having condition - CHECK_STATUS(GenHavingFilter(&(dynamic_cast(node))->having_condition_, + CHECK_STATUS(GenHavingFilter(&(dynamic_cast(node))->having_condition_, project_op->producers()[0]->schemas_ctx())); break; } @@ -1183,8 +1183,8 @@ Status BatchModeTransformer::CreatePhysicalProjectNode( break; } case kAggregation: { - PhysicalAggrerationNode* agg_op = nullptr; - CHECK_STATUS(CreateOp(&agg_op, depend, + PhysicalAggregationNode* agg_op = nullptr; + CHECK_STATUS(CreateOp(&agg_op, depend, column_projects, having_condition)); *output = agg_op; break;