diff --git a/src/sql/engine/join/ob_merge_join_vec_op.cpp b/src/sql/engine/join/ob_merge_join_vec_op.cpp index 750fdd01b8..dede222ac2 100644 --- a/src/sql/engine/join/ob_merge_join_vec_op.cpp +++ b/src/sql/engine/join/ob_merge_join_vec_op.cpp @@ -39,7 +39,11 @@ OB_SERIALIZE_MEMBER((ObMergeJoinVecSpec, ObJoinVecSpec), equal_cond_infos_, merge_directions_, left_child_fetcher_all_exprs_, - right_child_fetcher_all_exprs_); + right_child_fetcher_all_exprs_, + left_child_fetcher_equal_keys_, + right_child_fetcher_equal_keys_, + left_child_fetcher_equal_keys_idx_, + right_child_fetcher_equal_keys_idx_); OB_SERIALIZE_MEMBER(ObMergeJoinVecSpec::EqualConditionInfo, expr_, ser_eval_func_, is_opposite_); const int64_t ObMergeJoinVecSpec::MERGE_DIRECTION_ASC = 1; diff --git a/src/sql/engine/join/ob_merge_join_vec_op.h b/src/sql/engine/join/ob_merge_join_vec_op.h index 2885f6b331..9acd5fd9a1 100644 --- a/src/sql/engine/join/ob_merge_join_vec_op.h +++ b/src/sql/engine/join/ob_merge_join_vec_op.h @@ -64,7 +64,11 @@ public: equal_cond_infos_(alloc), merge_directions_(alloc), left_child_fetcher_all_exprs_(alloc), - right_child_fetcher_all_exprs_(alloc) + right_child_fetcher_all_exprs_(alloc), + left_child_fetcher_equal_keys_(alloc), + right_child_fetcher_equal_keys_(alloc), + left_child_fetcher_equal_keys_idx_(alloc), + right_child_fetcher_equal_keys_idx_(alloc) {} virtual ~ObMergeJoinVecSpec() {}; @@ -96,6 +100,10 @@ public: common::ObFixedArray merge_directions_; ExprFixedArray left_child_fetcher_all_exprs_; ExprFixedArray right_child_fetcher_all_exprs_; + ExprFixedArray left_child_fetcher_equal_keys_; + ExprFixedArray right_child_fetcher_equal_keys_; + common::ObFixedArray left_child_fetcher_equal_keys_idx_; + common::ObFixedArray right_child_fetcher_equal_keys_idx_; private: DISALLOW_COPY_AND_ASSIGN(ObMergeJoinVecSpec);