aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorInnokentii Mokin <innokentii@ydb.tech>2024-12-04 13:52:48 +0300
committerGitHub <noreply@github.com>2024-12-04 13:52:48 +0300
commit152e66b33392878fc8a18dd5e980bc04280fe2d8 (patch)
tree0d302d51f3af49741e23d2e5a4d5a3facaa12fa2
parent778313b4edf12d5786ac6c8cc1525a38238b175f (diff)
downloadydb-152e66b33392878fc8a18dd5e980bc04280fe2d8.tar.gz
Add more logs to backup-related components (#12277)
-rw-r--r--ydb/core/backup/impl/local_partition_reader.cpp6
-rw-r--r--ydb/core/tx/datashard/incr_restore_scan.cpp4
-rw-r--r--ydb/core/tx/replication/service/base_table_writer.cpp2
-rw-r--r--ydb/core/tx/schemeshard/schemeshard__operation_copy_table.cpp12
-rw-r--r--ydb/core/tx/schemeshard/schemeshard__operation_create_table.cpp9
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;
}