summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoryumkam <[email protected]>2025-09-26 19:00:32 +0300
committerGitHub <[email protected]>2025-09-26 16:00:32 +0000
commit580503a145c75b341cabdd6aed063fda93f499c3 (patch)
tree1debb39d75548ec1742e48bf0f039560fa231d39
parentbd3eddda222907fc5db9fce943cde84f4b73ef22 (diff)
pq rd: get rid of New watermark (empty maybe) log spam (#25882)
-rw-r--r--ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp b/ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp
index 976757f6cc2..0a3e4c66e01 100644
--- a/ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp
+++ b/ydb/library/yql/providers/pq/async_io/dq_pq_rd_read_actor.cpp
@@ -1148,8 +1148,10 @@ void TDqPqRdReadActor::Handle(NFq::TEvRowDispatcher::TEvMessageBatch::TPtr& ev)
newWatermark = *maybeNewWatermark;
}
- SRC_LOG_D("SessionId: " << GetSessionId() << " New watermark " << newWatermark << " was generated");
- activeBatch.Watermark = newWatermark;
+ if (newWatermark) {
+ SRC_LOG_D("SessionId: " << GetSessionId() << " New watermark " << newWatermark << " was generated");
+ activeBatch.Watermark = newWatermark;
+ }
}
Parent->NotifyCA();