diff options
author | Innokentii Mokin <innokentii@ydb.tech> | 2024-12-04 13:52:48 +0300 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-12-04 13:52:48 +0300 |
commit | 152e66b33392878fc8a18dd5e980bc04280fe2d8 (patch) | |
tree | 0d302d51f3af49741e23d2e5a4d5a3facaa12fa2 | |
parent | 778313b4edf12d5786ac6c8cc1525a38238b175f (diff) | |
download | ydb-152e66b33392878fc8a18dd5e980bc04280fe2d8.tar.gz |
Add more logs to backup-related components (#12277)
5 files changed, 28 insertions, 5 deletions
diff --git a/ydb/core/backup/impl/local_partition_reader.cpp b/ydb/core/backup/impl/local_partition_reader.cpp index 34a5162076..b7a476693a 100644 --- a/ydb/core/backup/impl/local_partition_reader.cpp +++ b/ydb/core/backup/impl/local_partition_reader.cpp @@ -37,7 +37,7 @@ private: if (!LogPrefix) { LogPrefix = TStringBuilder() << "[LocalPartitionReader]" - << "[" << PQTablet << "]" + << PQTablet << "[" << Partition << "]" << SelfId() << " "; } @@ -62,14 +62,14 @@ private: void HandleInit(TEvWorker::TEvHandshake::TPtr& ev) { Worker = ev->Sender; - LOG_D("Handshake" + LOG_D("HandleInit TEvWorker::TEvHandshake" << ": worker# " << Worker); Send(PQTablet, CreateGetOffsetRequest().Release()); } void HandleInit(TEvPersQueue::TEvResponse::TPtr& ev) { - LOG_D("Handle " << ev->Get()->ToString()); + LOG_D("HandleInit " << ev->Get()->ToString()); auto& record = ev->Get()->Record; if (record.GetErrorCode() == NPersQueue::NErrorCode::INITIALIZING) { Schedule(TDuration::Seconds(1), new NActors::TEvents::TEvWakeup); diff --git a/ydb/core/tx/datashard/incr_restore_scan.cpp b/ydb/core/tx/datashard/incr_restore_scan.cpp index d40abbb571..6a3db21d63 100644 --- a/ydb/core/tx/datashard/incr_restore_scan.cpp +++ b/ydb/core/tx/datashard/incr_restore_scan.cpp @@ -30,8 +30,8 @@ class TIncrementalRestoreScan LogPrefix = TStringBuilder() << "[TIncrementalRestoreScan]" << "[" << TxId << "]" - << "[" << SourcePathId << "]" - << "[" << TargetPathId << "]" + << SourcePathId + << TargetPathId << SelfId() /* contains brackets */ << " "; } diff --git a/ydb/core/tx/replication/service/base_table_writer.cpp b/ydb/core/tx/replication/service/base_table_writer.cpp index fdc7276019..159b405848 100644 --- a/ydb/core/tx/replication/service/base_table_writer.cpp +++ b/ydb/core/tx/replication/service/base_table_writer.cpp @@ -411,6 +411,8 @@ class TLocalTableWriter CreateSenders(NChangeExchange::MakePartitionIds(KeyDesc->GetPartitions())); if (!Initialized) { + LOG_D("Send handshake" + << ": worker# " << Worker); Send(Worker, new TEvWorker::TEvHandshake()); Initialized = true; } diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_copy_table.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_copy_table.cpp index 125acdfa22..4445a15470 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_copy_table.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_copy_table.cpp @@ -717,6 +717,18 @@ public: dstPath.Base()->IncShardsInside(shardsToCreate); parent.Base()->IncAliveChildren(1, isBackup); + LOG_TRACE_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, + "TCopyTable Propose creating new table" + << " opId# " << OperationId + << " srcPath# " << srcPath.PathString() + << " srcPathId# " << srcPath.Base()->PathId + << " path# " << dstPath.PathString() + << " pathId# " << newTable->PathId + << " withNewCdc# " << (Transaction.HasCreateCdcStream() ? "true" : "false") + << " schemeshard# " << ssId + << " tx# " << Transaction.DebugString() + ); + SetState(NextState()); return result; } diff --git a/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp b/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp index cc140faf3e..adb9564aa8 100644 --- a/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp +++ b/ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp @@ -730,6 +730,15 @@ public: dstPath.Base()->IncShardsInside(shardsToCreate); parentPath.Base()->IncAliveChildren(); + LOG_TRACE_S(context.Ctx, NKikimrServices::FLAT_TX_SCHEMESHARD, + "TCreateTable Propose creating new table" + << " opId# " << OperationId + << " path# " << dstPath.PathString() + << " pathId# " << newTable->PathId + << " schemeshard# " << ssId + << " tx# " << Transaction.DebugString() + ); + SetState(NextState()); return result; } |