diff --git a/src/sql/engine/join/ob_merge_join_op.cpp b/src/sql/engine/join/ob_merge_join_op.cpp index c2205bc2f..272fbfbb6 100644 --- a/src/sql/engine/join/ob_merge_join_op.cpp +++ b/src/sql/engine/join/ob_merge_join_op.cpp @@ -134,6 +134,8 @@ int ObMergeJoinOp::inner_open() const ExprFixedArray &left_outputs = left_->get_spec().output_; const ExprFixedArray &right_outputs = right_->get_spec().output_; const uint64_t tenant_id = ctx_.get_my_session()->get_effective_tenant_id(); + match_groups_.set_attr(ObMemAttr(tenant_id, "SqlMJGroups")); + output_cache_.set_attr(ObMemAttr(tenant_id, "SqlMJOutput")); const ObIArray &equal_cond_infos = MY_SPEC.equal_cond_infos_; const int64_t left_width = left_->get_spec().width_;