aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorazevaykin <azevaykin@yandex-team.com>2023-07-27 12:22:46 +0300
committerazevaykin <azevaykin@yandex-team.com>2023-07-27 12:22:46 +0300
commit565fe9166e5f84fa615bf4cd7b3bd4e3a9235f23 (patch)
treed9f1bd02ddbc535f68c5885022c19cfc7a7837e3
parent3a6dc213690b48dfa360d9ced0091d077a2dca6e (diff)
downloadydb-565fe9166e5f84fa615bf4cd7b3bd4e3a9235f23.tar.gz
Reduce log verbosity level
-rw-r--r--ydb/core/client/server/msgbus_server_pq_metacache.cpp2
-rw-r--r--ydb/core/persqueue/partition_write.cpp8
2 files changed, 5 insertions, 5 deletions
diff --git a/ydb/core/client/server/msgbus_server_pq_metacache.cpp b/ydb/core/client/server/msgbus_server_pq_metacache.cpp
index dcb9138e89..84a65394ba 100644
--- a/ydb/core/client/server/msgbus_server_pq_metacache.cpp
+++ b/ydb/core/client/server/msgbus_server_pq_metacache.cpp
@@ -245,7 +245,7 @@ private:
}
void HandleQueryResponse(NKqp::TEvKqp::TEvQueryResponse::TPtr& ev, const TActorContext& ctx) {
- LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "HandleQueryResponse TEvQueryResponse");
+ LOG_TRACE_S(ctx, NKikimrServices::PQ_METACACHE, "HandleQueryResponse TEvQueryResponse");
if (ev->Cookie != (ui64)Generation->Val()) {
LOG_DEBUG_S(ctx, NKikimrServices::PQ_METACACHE, "stale response with generation " << ev->Cookie << ", actual is " << Generation->Val());
diff --git a/ydb/core/persqueue/partition_write.cpp b/ydb/core/persqueue/partition_write.cpp
index 110f23c793..1fe69aa262 100644
--- a/ydb/core/persqueue/partition_write.cpp
+++ b/ydb/core/persqueue/partition_write.cpp
@@ -186,7 +186,7 @@ void TPartition::Handle(TEvPQ::TEvChangeOwner::TPtr& ev, const TActorContext& ct
}
void TPartition::ProcessReserveRequests(const TActorContext& ctx) {
- LOG_DEBUG_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::ProcessReserveRequests. Partition: " << Partition);
+ LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::ProcessReserveRequests. Partition: " << Partition);
const ui64 maxWriteInflightSize = Config.GetPartitionConfig().GetMaxWriteInflightSize();
@@ -265,7 +265,7 @@ void TPartition::HandleOnIdle(TEvPQ::TEvWrite::TPtr& ev, const TActorContext& ct
}
void TPartition::AnswerCurrentWrites(const TActorContext& ctx) {
- LOG_DEBUG_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::AnswerCurrentWrites. Partition: " << Partition);
+ LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::AnswerCurrentWrites. Partition: " << Partition);
ui64 offset = EndOffset;
while (!Responses.empty()) {
@@ -1270,7 +1270,7 @@ void TPartition::Handle(TEvPQ::TEvQuotaDeadlineCheck::TPtr&, const TActorContext
}
bool TPartition::ProcessWrites(TEvKeyValue::TEvRequest* request, TInstant now, const TActorContext& ctx) {
- LOG_DEBUG_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::ProcessWrites. Partition: " << Partition);
+ LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::ProcessWrites. Partition: " << Partition);
FilterDeadlinedWrites(ctx);
@@ -1369,7 +1369,7 @@ void TPartition::FilterDeadlinedWrites(const TActorContext& ctx) {
void TPartition::HandleWrites(const TActorContext& ctx) {
- LOG_DEBUG_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::HandleWrites. Partition: " << Partition);
+ LOG_TRACE_S(ctx, NKikimrServices::PERSQUEUE, "TPartition::HandleWrites. Partition: " << Partition);
Become(&TThis::StateWrite);