Skip to content

Commit 003c739

Browse files
authored
stable-25-1: Change INFO log level on NOTICE for some logs in data erasure (#17897) (#18414)
2 parents d2fcde1 + 351b7b4 commit 003c739

File tree

2 files changed

+16
-16
lines changed

2 files changed

+16
-16
lines changed

ydb/core/tx/schemeshard/schemeshard__root_data_erasure_manager.cpp

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ void TRootDataErasureManager::UpdateConfig(const NKikimrConfig::TDataErasureConf
6262
void TRootDataErasureManager::Start() {
6363
TDataErasureManager::Start();
6464
const auto ctx = SchemeShard->ActorContext();
65-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
65+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
6666
"[RootDataErasureManager] Start: Status# " << static_cast<ui32>(Status));
6767

6868
Queue->Start();
@@ -80,7 +80,7 @@ void TRootDataErasureManager::Start() {
8080
void TRootDataErasureManager::Stop() {
8181
TDataErasureManager::Stop();
8282
const auto ctx = SchemeShard->ActorContext();
83-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
83+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
8484
"[RootDataErasureManager] Stop");
8585

8686
Queue->Stop();
@@ -134,7 +134,7 @@ void TRootDataErasureManager::Run(NIceDb::TNiceDb& db) {
134134
Schema::DataErasureGenerations::StartTime>(Status, StartTime.MicroSeconds());
135135

136136
const auto ctx = SchemeShard->ActorContext();
137-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
137+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
138138
"[RootDataErasureManager] Run: Queue.Size# " << Queue->Size()
139139
<< ", WaitingDataErasureTenants.size# " << WaitingDataErasureTenants.size()
140140
<< ", Status# " << static_cast<ui32>(Status));
@@ -152,7 +152,7 @@ void TRootDataErasureManager::Continue() {
152152
}
153153

154154
const auto ctx = SchemeShard->ActorContext();
155-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
155+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
156156
"[RootDataErasureManager] Continue: Queue.Size# " << Queue->Size()
157157
<< ", Status# " << static_cast<ui32>(Status));
158158
}
@@ -166,7 +166,7 @@ void TRootDataErasureManager::ScheduleDataErasureWakeup() {
166166
ctx.Schedule(CurrentWakeupInterval, new TEvSchemeShard::TEvWakeupToRunDataErasure);
167167
IsDataErasureWakeupScheduled = true;
168168

169-
LOG_DEBUG_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
169+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
170170
"[RootDataErasureManager] ScheduleDataErasureWakeup: Interval# " << CurrentWakeupInterval << ", Timestamp# " << AppData(ctx)->TimeProvider->Now());
171171
}
172172

@@ -193,7 +193,7 @@ NOperationQueue::EStartStatus TRootDataErasureManager::StartDataErasure(const TP
193193

194194
const auto& tenantSchemeShardId = it->second->GetTenantSchemeShardID();
195195

196-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "[RootDataErasureManager] [Start] Data erasure "
196+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "[RootDataErasureManager] [Start] Data erasure "
197197
"for pathId# " << pathId
198198
<< ", tenant schemeshard# " << tenantSchemeShardId
199199
<< ", next wakeup# " << Queue->GetWakeupDelta()
@@ -344,13 +344,13 @@ void TRootDataErasureManager::ScheduleRequestToBSC() {
344344
ctx.Schedule(DataErasureBSCInterval, new TEvSchemeShard::TEvWakeupToRunDataErasureBSC);
345345
IsRequestToBSCScheduled = true;
346346

347-
LOG_DEBUG_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
347+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
348348
"[RootDataErasureManager] ScheduleRequestToBSC: Interval# " << DataErasureBSCInterval);
349349
}
350350

351351
void TRootDataErasureManager::SendRequestToBSC() {
352352
auto ctx = SchemeShard->ActorContext();
353-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
353+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
354354
"[RootDataErasureManager] SendRequestToBSC: Generation# " << Generation);
355355

356356
IsRequestToBSCScheduled = false;
@@ -373,7 +373,7 @@ void TRootDataErasureManager::Complete() {
373373
ScheduleDataErasureWakeup();
374374
}
375375

376-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
376+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
377377
"[RootDataErasureManager] Complete: Generation# " << Generation
378378
<< ", duration# " << dataErasureDuration.Seconds() << " s");
379379
}
@@ -641,11 +641,11 @@ struct TSchemeShard::TTxCompleteDataErasureBSC : public TSchemeShard::TRwTxBase
641641

642642
NIceDb::TNiceDb db(txc.DB);
643643
if (record.GetCompleted()) {
644-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "TTxCompleteDataErasureBSC: Data shred in BSC is completed");
644+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "TTxCompleteDataErasureBSC: Data shred in BSC is completed");
645645
manager->Complete();
646646
db.Table<Schema::DataErasureGenerations>().Key(Self->DataErasureManager->GetGeneration()).Update<Schema::DataErasureGenerations::Status>(Self->DataErasureManager->GetStatus());
647647
} else {
648-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "TTxCompleteDataErasureBSC: Progress data shred in BSC " << static_cast<double>(record.GetProgress10k()) / 100 << "%");
648+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, "TTxCompleteDataErasureBSC: Progress data shred in BSC " << static_cast<double>(record.GetProgress10k()) / 100 << "%");
649649
NeedScheduleRequestToBSC = true;
650650
}
651651
}

ydb/core/tx/schemeshard/schemeshard__tenant_data_erasure_manager.cpp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ void TTenantDataErasureManager::UpdateConfig(const NKikimrConfig::TDataErasureCo
6161
void TTenantDataErasureManager::Start() {
6262
TDataErasureManager::Start();
6363
const auto ctx = SchemeShard->ActorContext();
64-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
64+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
6565
"[TenantDataErasureManager] Start: Status# " << static_cast<ui32>(Status));
6666

6767
Queue->Start();
@@ -76,7 +76,7 @@ void TTenantDataErasureManager::Start() {
7676
void TTenantDataErasureManager::Stop() {
7777
TDataErasureManager::Stop();
7878
const auto ctx = SchemeShard->ActorContext();
79-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
79+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
8080
"[TenantDataErasureManager] Stop");
8181

8282
Queue->Stop();
@@ -134,7 +134,7 @@ void TTenantDataErasureManager::Run(NIceDb::TNiceDb& db) {
134134
db.Table<Schema::TenantDataErasureGenerations>().Key(Generation).Update<Schema::TenantDataErasureGenerations::Status>(Status);
135135

136136
const auto ctx = SchemeShard->ActorContext();
137-
LOG_TRACE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
137+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
138138
"[TenantDataErasureManager] Run: Queue.Size# " << Queue->Size()
139139
<< ", WaitingDataErasureShards.size# " << WaitingDataErasureShards.size()
140140
<< ", Status# " << static_cast<ui32>(Status));
@@ -322,7 +322,7 @@ void TTenantDataErasureManager::OnDone(const TTabletId& tabletId, NIceDb::TNiceD
322322
UpdateMetrics();
323323

324324
if (WaitingDataErasureShards.empty()) {
325-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
325+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
326326
"[TenantDataErasureManager] Data erasure in shards is completed. Send response to root schemeshard");
327327
Complete();
328328
db.Table<Schema::TenantDataErasureGenerations>().Key(Generation).Update<Schema::TenantDataErasureGenerations::Status>(Status);
@@ -345,7 +345,7 @@ void TTenantDataErasureManager::Complete() {
345345
Status = EDataErasureStatus::COMPLETED;
346346

347347
auto ctx = SchemeShard->ActorContext();
348-
LOG_INFO_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
348+
LOG_NOTICE_S(ctx, NKikimrServices::FLAT_TX_SCHEMESHARD,
349349
"[TenantDataErasureManager] Complete: Generation# " << Generation);
350350
}
351351

0 commit comments

Comments
 (0)