yiguolei commented on code in PR #47620:
URL: https://github.com/apache/doris/pull/47620#discussion_r1947413975
##########
be/src/pipeline/local_exchange/local_exchanger.h:
##########
@@ -229,15 +232,18 @@ struct BlockWrapper {
// free block will not incur any bad result so just ignore the
return value.
shared_state->exchanger->_free_blocks.enqueue(std::move(data_block));
}
- }
+ };
}
-
- void unref(LocalExchangeSharedState* shared_state = nullptr, int
channel_id = 0) {
- unref(shared_state, data_block.allocated_bytes(), channel_id);
+ void record_channel_id(int channel_id, bool update_total_mem_usage) {
+ channel_ids.push_back(channel_id);
Review Comment:
这些东东，为什么不能再构造的时候，就直接确定下来？
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
