summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorhor911 <[email protected]>2023-05-09 11:40:26 +0300
committerhor911 <[email protected]>2023-05-09 11:40:26 +0300
commit836392678a6bc233288b312c4953fffcf646b8fc (patch)
treede30961a8748f40cfc151a984752738dc471ec7b
parent0e76812af073f4215087ba85c7a47149f6029f5b (diff)
Decrease level of repeated logs to TRACE
-rw-r--r--ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h6
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
index d78e50d9973..6fb88ba70d7 100644
--- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
+++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h
@@ -389,7 +389,7 @@ protected:
ProcessOutputsState.ChannelsReady = false;
ProcessOutputsState.HasDataToSend = true;
ProcessOutputsState.AllOutputsFinished = false;
- CA_LOG_D("Can not drain channelId: " << channelId << ", no dst actor id");
+ CA_LOG_T("Can not drain channelId: " << channelId << ", no dst actor id");
if (Y_UNLIKELY(outputChannel.Stats)) {
outputChannel.Stats->NoDstActorId++;
}
@@ -404,7 +404,7 @@ protected:
ProcessOutputsState.HasDataToSend |= !outputChannel.Finished;
}
} else {
- CA_LOG_D("Do not drain channelId: " << channelId << ", finished");
+ CA_LOG_T("Do not drain channelId: " << channelId << ", finished");
ProcessOutputsState.AllOutputsFinished &= outputChannel.Finished;
}
}
@@ -1333,7 +1333,7 @@ private:
bool hasCheckpoint = channel->Pop(checkpoint);
if (!hasData && !hasWatermark && !hasCheckpoint) {
if (!channel->IsFinished()) {
- CA_LOG_D("output channelId: " << channel->GetChannelId() << ", nothing to send and is not finished");
+ CA_LOG_T("output channelId: " << channel->GetChannelId() << ", nothing to send and is not finished");
return 0; // channel is empty and not finished yet
}
}