-
Notifications
You must be signed in to change notification settings - Fork 604
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Introduce locality counters for single node tx. (#13415) #13735
base: stream-nb-24-3
Are you sure you want to change the base?
Conversation
TotalSingleNodeReqCount - increases if tx touches the only one node (all shards located on the same node) NonLocalSingleNodeReqCount - increases if tx touches the only one node and this node is same with session node (node where located kqp session and grpc request accepted) * New feature
⚪
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
⚪
🟢
*please be aware that the difference is based on comparing your commit and the last completed build from the post-commit, check comparation |
@@ -1860,6 +1861,10 @@ class TKqpExecuterBase : public TActorBootstrapped<TDerived> { | |||
LOG_N("Full stats: " << response.GetResult().GetStats()); | |||
} | |||
} | |||
|
|||
for (const auto nodeId : ParticipantNodes) { | |||
response.MutableResult()->AddParticipantNodes(nodeId); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
это же локальное сообщение, зачем в протобуф перекладывать?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
По аналогии со статистикой. Вообще там не очевидно как использовать поля в TEvTxResponse
TotalSingleNodeReqCount - increases if tx touches the only one node (all shards located on the same node)
NonLocalSingleNodeReqCount - increases if tx touches the only one node and this node is same with session node (node where located kqp session and grpc request accepted)
Changelog entry
...
Changelog category
Additional information
...