Skip to content

Commit 3f96a63

Browse files
authored
YQ-2862 Move logs to api (#2376)
1 parent 4c13a9e commit 3f96a63

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

ydb/library/yql/providers/pq/async_io/dq_pq_read_actor.cpp

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -437,7 +437,6 @@ class TDqPqReadActor : public NActors::TActor<TDqPqReadActor>, public IDqCompute
437437

438438
for (const auto& [partitionStream, ranges] : readyBatch.OffsetRanges) {
439439
for (const auto& [start, end] : ranges) {
440-
SRC_LOG_D("Add range to commit [" << start << ", " << end << ")");
441440
CurrentDeferredCommit.Add(partitionStream, start, end);
442441
if (!CurrentDeferredCommitOffset) {
443442
CurrentDeferredCommitOffset = std::make_pair(start, end);

ydb/public/sdk/cpp/client/ydb_persqueue_core/impl/read_session.ipp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -62,6 +62,9 @@ TLog TPartitionStreamImpl<UseMigrationProtocol>::GetLog() const {
6262

6363
template<bool UseMigrationProtocol>
6464
void TPartitionStreamImpl<UseMigrationProtocol>::Commit(ui64 startOffset, ui64 endOffset) {
65+
66+
LOG_LAZY(GetLog(), TLOG_INFO, TStringBuilder() << "Commit offsets (stream): [" << startOffset << ", " << endOffset << "). Partition stream id: " << GetPartitionStreamId(this));
67+
6568
std::vector<std::pair<ui64, ui64>> toCommit;
6669
if (auto sessionShared = CbContext->LockShared()) {
6770
Y_ABORT_UNLESS(endOffset > startOffset);

0 commit comments

Comments
 (0)