diff options
author | epbugaev <epbugaev@yandex-team.com> | 2023-09-04 13:53:54 +0300 |
---|---|---|
committer | epbugaev <epbugaev@yandex-team.com> | 2023-09-04 14:08:51 +0300 |
commit | 0b17e1e09fcfd681baa045307cd3d96e67407238 (patch) | |
tree | 80108fb4950719efe175bd3fc066adcc58a6ff09 | |
parent | 0c88357d27a69ec5c5d826ea211d6942405fb3b5 (diff) | |
download | ydb-0b17e1e09fcfd681baa045307cd3d96e67407238.tar.gz |
Add debug info for vanilla job crashes
Add debug logging
-rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp index eb4e7b4063..56bd16eb33 100644 --- a/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp +++ b/ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp @@ -574,9 +574,11 @@ private: // If the channel has finished, then the data received after drain is no longer needed const bool shouldSkipData = Channels->ShouldSkipData(outputChannel.ChannelId); if (!shouldSkipData && !Channels->CanSendChannelData(outputChannel.ChannelId)) { // When channel will be connected, they will call resume execution. + CA_LOG_D("TrySendAsyncChannelData return false because Channel can't send channel data"); return false; } if (!shouldSkipData && !Channels->HasFreeMemoryInChannel(outputChannel.ChannelId)) { + CA_LOG_D("TrySendAsyncChannelData return false because No free memory in channel"); return false; } |