-
Notifications
You must be signed in to change notification settings - Fork 638
add missing monitoring metrics for column shards #7314
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
Conversation
211aed8
to
c35dccf
Compare
⚪ ⚪
🟢
*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 |
761130e
to
8c5596e
Compare
⚪
🟢
*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 |
ColumnShardScanRows_->Set(ColumnShardScannedRows_->Val()); | ||
ColumnShardScanBytes_->Set(ColumnShardScannedBytes_->Val()); | ||
ColumnShardBulkUpsertRows_->Set(ColumnShardUpsertBlobsWritten_->Val()); | ||
ColumnShardBulkUpsertBytes_->Set(ColumnShardUpsertBytesWritten_->Val()); | ||
ColumnShardWriteRows_->Set(ColumnShardOperationsRowsWritten_->Val()); |
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.
В ColumnShardWrite* и ColumnShardBulkUpsert* одинаковые значения, потому что сейчас непонятно, как на стороне шарда различать записи через bulk upload от остальных -- когда поддержим транзакции, надо будет разделить эти метрики
@@ -128,8 +128,12 @@ void TColumnShard::Handle(TEvPrivate::TEvWriteBlobsResult::TPtr& ev, const TActo | |||
Counters.GetCSCounters().OnFailedWriteResponse(EWriteFailReason::PutBlob); | |||
wBuffer.RemoveData(aggr, StoragesManager->GetInsertOperator()); | |||
} else { | |||
ui64 rows = 0; | |||
for (auto& batch : aggr->GetSplittedBlobs()) { |
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.
сделай aggr->GetRecordsCount()
⚪
🟢
*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 |
Track the following Monitoring metrics for column shards:
table.columnshard.used_core_percents
table.columnshard.read.bytes
table.columnshard.read.rows
table.columnshard.write.rows
table.columnshard.write.bytes
table.columnshard.erase.rows
table.columnshard.erase.bytes