diff options
| author | yumkam <[email protected]> | 2025-09-26 19:00:32 +0300 |
|---|---|---|
| committer | GitHub <[email protected]> | 2025-09-26 16:00:32 +0000 |
| commit | 580503a145c75b341cabdd6aed063fda93f499c3 (patch) | |
| tree | 1debb39d75548ec1742e48bf0f039560fa231d39 | |
| parent | bd3eddda222907fc5db9fce943cde84f4b73ef22 (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.cpp | 6 |
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(); |
