Skip to content

Commit 05ccc0b

Browse files
kungakunga
committed
Low BUILD_INDEX scan log levels (#19633)
1 parent c0cae6c commit 05ccc0b

File tree

6 files changed

+24
-24
lines changed

6 files changed

+24
-24
lines changed

‎ydb/core/tx/datashard/build_index/local_kmeans.cpp

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -276,7 +276,7 @@ class TLocalKMeansScan final : public TLocalKMeansScanBase {
276276
EScan Seek(TLead& lead, ui64 seq) noexcept final
277277
{
278278
try {
279-
LOG_D("Seek " << seq << " " << Debug());
279+
LOG_T("Seek " << seq << " " << Debug());
280280

281281
if (IsExhausted) {
282282
return Uploader.CanFinish()
@@ -296,7 +296,7 @@ class TLocalKMeansScan final : public TLocalKMeansScanBase {
296296
EScan Feed(TArrayRef<const TCell> key, const TRow& row) noexcept final
297297
{
298298
try {
299-
LOG_T("Feed " << Debug());
299+
// LOG_T("Feed " << Debug());
300300

301301
++ReadRows;
302302
ReadBytes += CountBytes(key, row);
@@ -335,7 +335,7 @@ class TLocalKMeansScan final : public TLocalKMeansScanBase {
335335
EScan Exhausted() noexcept final
336336
{
337337
try {
338-
LOG_D("Exhausted " << Debug());
338+
LOG_T("Exhausted " << Debug());
339339

340340
if (!FinishPrefix()) {
341341
return EScan::Reset;
@@ -356,28 +356,28 @@ class TLocalKMeansScan final : public TLocalKMeansScanBase {
356356
{
357357
if (FinishPrefixImpl()) {
358358
StartNewPrefix();
359-
LOG_D("FinishPrefix finished " << Debug());
359+
LOG_T("FinishPrefix finished " << Debug());
360360
return true;
361361
} else {
362362
IsFirstPrefixFeed = false;
363363

364364
if (IsPrefixRowsValid) {
365-
LOG_D("FinishPrefix not finished, manually feeding " << PrefixRows.Size() << " saved rows " << Debug());
365+
LOG_T("FinishPrefix not finished, manually feeding " << PrefixRows.Size() << " saved rows " << Debug());
366366
for (ui64 iteration = 0; ; iteration++) {
367367
for (const auto& [key, row_] : *PrefixRows.GetRowsData()) {
368368
TSerializedCellVec row(row_);
369369
Feed(key.GetCells(), row.GetCells());
370370
}
371371
if (FinishPrefixImpl()) {
372372
StartNewPrefix();
373-
LOG_D("FinishPrefix finished in " << iteration << " iterations " << Debug());
373+
LOG_T("FinishPrefix finished in " << iteration << " iterations " << Debug());
374374
return true;
375375
} else {
376-
LOG_D("FinishPrefix not finished in " << iteration << " iterations " << Debug());
376+
LOG_T("FinishPrefix not finished in " << iteration << " iterations " << Debug());
377377
}
378378
}
379379
} else {
380-
LOG_D("FinishPrefix not finished, rescanning rows " << Debug());
380+
LOG_T("FinishPrefix not finished, rescanning rows " << Debug());
381381
}
382382

383383
return false;

‎ydb/core/tx/datashard/build_index/prefix_kmeans.cpp

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -307,7 +307,7 @@ class TPrefixKMeansScan final : public TPrefixKMeansScanBase {
307307
EScan Seek(TLead& lead, ui64 seq) noexcept final
308308
{
309309
try {
310-
LOG_D("Seek " << seq << " " << Debug());
310+
LOG_T("Seek " << seq << " " << Debug());
311311

312312
if (IsExhausted) {
313313
return Uploader.CanFinish()
@@ -327,7 +327,7 @@ class TPrefixKMeansScan final : public TPrefixKMeansScanBase {
327327
EScan Feed(TArrayRef<const TCell> key, const TRow& row) noexcept final
328328
{
329329
try {
330-
LOG_T("Feed " << Debug());
330+
// LOG_T("Feed " << Debug());
331331

332332
++ReadRows;
333333
ReadBytes += CountBytes(key, row);
@@ -370,7 +370,7 @@ class TPrefixKMeansScan final : public TPrefixKMeansScanBase {
370370
EScan Exhausted() noexcept final
371371
{
372372
try {
373-
LOG_D("Exhausted " << Debug());
373+
LOG_T("Exhausted " << Debug());
374374

375375
if (!FinishPrefix()) {
376376
return EScan::Reset;
@@ -391,28 +391,28 @@ class TPrefixKMeansScan final : public TPrefixKMeansScanBase {
391391
{
392392
if (FinishPrefixImpl()) {
393393
StartNewPrefix();
394-
LOG_D("FinishPrefix finished " << Debug());
394+
LOG_T("FinishPrefix finished " << Debug());
395395
return true;
396396
} else {
397397
IsFirstPrefixFeed = false;
398398

399399
if (IsPrefixRowsValid) {
400-
LOG_D("FinishPrefix not finished, manually feeding " << PrefixRows.Size() << " saved rows " << Debug());
400+
LOG_T("FinishPrefix not finished, manually feeding " << PrefixRows.Size() << " saved rows " << Debug());
401401
for (ui64 iteration = 0; ; iteration++) {
402402
for (const auto& [key, row_] : *PrefixRows.GetRowsData()) {
403403
TSerializedCellVec row(row_);
404404
Feed(key.GetCells(), row.GetCells());
405405
}
406406
if (FinishPrefixImpl()) {
407407
StartNewPrefix();
408-
LOG_D("FinishPrefix finished in " << iteration << " iterations " << Debug());
408+
LOG_T("FinishPrefix finished in " << iteration << " iterations " << Debug());
409409
return true;
410410
} else {
411-
LOG_D("FinishPrefix not finished in " << iteration << " iterations " << Debug());
411+
LOG_T("FinishPrefix not finished in " << iteration << " iterations " << Debug());
412412
}
413413
}
414414
} else {
415-
LOG_D("FinishPrefix not finished, rescanning rows " << Debug());
415+
LOG_T("FinishPrefix not finished, rescanning rows " << Debug());
416416
}
417417

418418
return false;

‎ydb/core/tx/datashard/build_index/reshuffle_kmeans.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ class TReshuffleKMeansScan final : public TReshuffleKMeansScanBase {
235235
EScan Seek(TLead& lead, ui64 seq) noexcept final
236236
{
237237
try {
238-
LOG_D("Seek " << seq << " " << Debug());
238+
LOG_T("Seek " << seq << " " << Debug());
239239

240240
if (IsExhausted) {
241241
return Uploader.CanFinish()
@@ -255,7 +255,7 @@ class TReshuffleKMeansScan final : public TReshuffleKMeansScanBase {
255255
EScan Feed(TArrayRef<const TCell> key, const TRow& row) noexcept final
256256
{
257257
try {
258-
LOG_T("Feed " << Debug());
258+
// LOG_T("Feed " << Debug());
259259

260260
++ReadRows;
261261
ReadBytes += CountBytes(key, row);
@@ -272,7 +272,7 @@ class TReshuffleKMeansScan final : public TReshuffleKMeansScanBase {
272272
EScan Exhausted() noexcept final
273273
{
274274
try {
275-
LOG_D("Exhausted " << Debug());
275+
LOG_T("Exhausted " << Debug());
276276

277277
IsExhausted = true;
278278

‎ydb/core/tx/datashard/build_index/sample_k.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ class TSampleKScan final: public TActor<TSampleKScan>, public NTable::IScan {
116116

117117
EScan Seek(TLead& lead, ui64 seq) noexcept final {
118118
try {
119-
LOG_D("Seek " << seq << " " << Debug());
119+
LOG_T("Seek " << seq << " " << Debug());
120120

121121
lead = Lead;
122122

@@ -131,7 +131,7 @@ class TSampleKScan final: public TActor<TSampleKScan>, public NTable::IScan {
131131

132132
EScan Feed(TArrayRef<const TCell> key, const TRow& row) noexcept final {
133133
try {
134-
LOG_T("Feed " << Debug());
134+
// LOG_T("Feed " << Debug());
135135

136136
++ReadRows;
137137
ReadBytes += CountBytes(key, row);
@@ -156,7 +156,7 @@ class TSampleKScan final: public TActor<TSampleKScan>, public NTable::IScan {
156156
EScan Exhausted() noexcept final
157157
{
158158
try {
159-
LOG_D("Exhausted " << Debug());
159+
LOG_T("Exhausted " << Debug());
160160

161161
return EScan::Final;
162162
} catch (const std::exception& exc) {

‎ydb/core/tx/datashard/build_index/secondary_index.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -151,7 +151,7 @@ class TBuildScanUpload: public TActor<TBuildScanUpload<Activity>>, public NTable
151151

152152
template <typename TAddRow>
153153
EScan FeedImpl(TArrayRef<const TCell> key, const TRow& /*row*/, TAddRow&& addRow) noexcept {
154-
LOG_T("Feed key " << DebugPrintPoint(KeyTypes, key, *AppData()->TypeRegistry) << " " << Debug());
154+
// LOG_T("Feed key " << DebugPrintPoint(KeyTypes, key, *AppData()->TypeRegistry) << " " << Debug());
155155

156156
addRow();
157157

‎ydb/core/tx/schemeshard/schemeshard_build_index__progress.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ class TUploadSampleK: public TActorBootstrapped<TUploadSampleK> {
161161
}
162162

163163
void Handle(TEvTxUserProxy::TEvUploadRowsResponse::TPtr& ev) {
164-
LOG_T("Handle TEvUploadRowsResponse "
164+
LOG_D("Handle TEvUploadRowsResponse "
165165
<< Debug()
166166
<< " Uploader: " << Uploader.ToString()
167167
<< " ev->Sender: " << ev->Sender.ToString());

0 commit comments

Comments
 (0)