deal with datahub memory leak
This commit is contained in:
@ -52,7 +52,9 @@ public:
|
|||||||
{}
|
{}
|
||||||
~ObWinbufPieceMsg() = default;
|
~ObWinbufPieceMsg() = default;
|
||||||
void reset()
|
void reset()
|
||||||
{}
|
{
|
||||||
|
deseria_allocator_.reset();
|
||||||
|
}
|
||||||
INHERIT_TO_STRING_KV("meta", ObDatahubPieceMsg<dtl::ObDtlMsgType::DH_WINBUF_PIECE_MSG>, K_(op_id));
|
INHERIT_TO_STRING_KV("meta", ObDatahubPieceMsg<dtl::ObDtlMsgType::DH_WINBUF_PIECE_MSG>, K_(op_id));
|
||||||
|
|
||||||
public:
|
public:
|
||||||
@ -89,6 +91,7 @@ public:
|
|||||||
is_datum_ = false;
|
is_datum_ = false;
|
||||||
row_store_.reset();
|
row_store_.reset();
|
||||||
datum_store_.reset();
|
datum_store_.reset();
|
||||||
|
assign_allocator_.reset();
|
||||||
}
|
}
|
||||||
VIRTUAL_TO_STRING_KV(K_(ready_state));
|
VIRTUAL_TO_STRING_KV(K_(ready_state));
|
||||||
int ready_state_;
|
int ready_state_;
|
||||||
|
|||||||
Reference in New Issue
Block a user