aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorepbugaev <epbugaev@yandex-team.com>2023-09-04 13:53:54 +0300
committerepbugaev <epbugaev@yandex-team.com>2023-09-04 14:08:51 +0300
commit0b17e1e09fcfd681baa045307cd3d96e67407238 (patch)
tree80108fb4950719efe175bd3fc066adcc58a6ff09
parent0c88357d27a69ec5c5d826ea211d6942405fb3b5 (diff)
downloadydb-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.cpp2
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;
}