Skip to content

Commit fba54d9

Browse files
committed
Add Locks info from ydb-platform#31699
1 parent 8ad9a71 commit fba54d9

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

ydb/core/kqp/executer_actor/kqp_executer_stats.cpp

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1047,6 +1047,15 @@ void TQueryExecutionStats::UpdateTaskStats(ui64 taskId, const NYql::NDqProto::TD
10471047
UpdateQueryTables(taskStats, txStats);
10481048
}
10491049

1050+
// Extract lock stats from task extra stats (populated by read actors for broken locks)
1051+
if (taskStats.HasExtra()) {
1052+
NKqpProto::TKqpTaskExtraStats extraStats;
1053+
if (taskStats.GetExtra().UnpackTo(&extraStats)) {
1054+
LocksBrokenAsBreaker += extraStats.GetLockStats().GetBrokenAsBreaker();
1055+
LocksBrokenAsVictim += extraStats.GetLockStats().GetBrokenAsVictim();
1056+
}
1057+
}
1058+
10501059
if (CollectBasicStats(StatsMode)) {
10511060
if (CollectFullStats(StatsMode)) {
10521061
auto stageId = TasksGraph->GetTask(taskId).StageId;

0 commit comments

Comments
 (0)