Skip to content

Commit 6a4b739

Browse files
authored
Add table id to DataShard integrity trails (#11248)
1 parent f12f073 commit 6a4b739

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

ydb/core/tx/datashard/datashard_integrity_trails.h

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,7 @@ inline void LogIntegrityTrailsKeys(const NActors::TActorContext& ctx, const ui64
5656
if (IS_DEBUG_LOG_ENABLED(NKikimrServices::DATA_INTEGRITY)) {
5757
if (keys.HasWrites()) {
5858
const int batchSize = 10;
59+
bool first = true;
5960
for (size_t offset = 0; offset < keys.Keys.size(); offset += batchSize) {
6061
TStringStream ss;
6162

@@ -71,6 +72,11 @@ inline void LogIntegrityTrailsKeys(const NActors::TActorContext& ctx, const ui64
7172
continue;
7273
}
7374

75+
if (first) {
76+
LogKeyValue("TableId", ToString(keyDef->TableId), ss);
77+
first = false;
78+
}
79+
7480
auto& range = keyDef->Range;
7581
TString rowOp;
7682
switch (keyDef->RowOperation) {

0 commit comments

Comments
 (0)