This is an automated email from the ASF dual-hosted git repository.
zhangstar333 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new a6f9df70969 [LOG] Add fatal log in exchange sink buffer (#26594)
a6f9df70969 is described below
commit a6f9df7096998093ead85703326e98639c0fea6e
Author: HappenLee <[email protected]>
AuthorDate: Wed Nov 8 21:52:21 2023 +0800
[LOG] Add fatal log in exchange sink buffer (#26594)
---
be/src/pipeline/exec/exchange_sink_buffer.cpp | 24 ++++++++++++++++++------
1 file changed, 18 insertions(+), 6 deletions(-)
diff --git a/be/src/pipeline/exec/exchange_sink_buffer.cpp
b/be/src/pipeline/exec/exchange_sink_buffer.cpp
index f450fa69605..4f93a39caa6 100644
--- a/be/src/pipeline/exec/exchange_sink_buffer.cpp
+++ b/be/src/pipeline/exec/exchange_sink_buffer.cpp
@@ -369,12 +369,24 @@ void
ExchangeSinkBuffer<Parent>::_construct_request(InstanceLoId id, PUniqueId f
template <typename Parent>
void ExchangeSinkBuffer<Parent>::_ended(InstanceLoId id) {
- std::unique_lock<std::mutex> lock(*_instance_to_package_queue_mutex[id]);
- if (!_rpc_channel_is_idle[id]) {
- _busy_channels--;
- _rpc_channel_is_idle[id] = true;
- if (_finish_dependency && _busy_channels == 0) {
- _finish_dependency->set_ready_to_finish();
+ if (!_instance_to_package_queue_mutex.template contains(id)) {
+ std::stringstream ss;
+ ss << "failed find the instance id:" << id
+ << " now mutex map size:" <<
_instance_to_package_queue_mutex.size();
+ for (const auto& p : _instance_to_package_queue_mutex) {
+ ss << " key:" << p.first << " value:" << p.second << "\n";
+ }
+ LOG(INFO) << ss.str();
+
+ LOG(FATAL) << "not find the instance id";
+ } else {
+ std::unique_lock<std::mutex>
lock(*_instance_to_package_queue_mutex[id]);
+ if (!_rpc_channel_is_idle[id]) {
+ _busy_channels--;
+ _rpc_channel_is_idle[id] = true;
+ if (_finish_dependency && _busy_channels == 0) {
+ _finish_dependency->set_ready_to_finish();
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
