Skip to content

Commit 0b84ae0

Browse files
authored
Fix histograms usage in KQP (#16842)
1 parent e07bd33 commit 0b84ae0

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

ydb/core/kqp/counters/kqp_counters.cpp

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -325,27 +325,27 @@ void TKqpCountersBase::ReportQueryWithFullScan() {
325325
}
326326

327327
void TKqpCountersBase::ReportQueryAffectedShards(ui64 shardsCount) {
328-
QueryAffectedShardsCount->Collect(shardsCount > Max<i64>() ? Max<i64>() : static_cast<i64>(shardsCount));
328+
QueryAffectedShardsCount->Collect(shardsCount);
329329
}
330330

331331
void TKqpCountersBase::ReportQueryReadSets(ui64 readSetsCount) {
332-
QueryReadSetsCount->Collect(readSetsCount > Max<i64>() ? Max<i64>() : static_cast<i64>(readSetsCount));
332+
QueryReadSetsCount->Collect(readSetsCount);
333333
}
334334

335335
void TKqpCountersBase::ReportQueryReadBytes(ui64 bytesCount) {
336-
QueryReadBytes->Collect(bytesCount > Max<i64>() ? Max<i64>() : static_cast<i64>(bytesCount));
336+
QueryReadBytes->Collect(bytesCount);
337337
}
338338

339339
void TKqpCountersBase::ReportQueryReadRows(ui64 rowsCount) {
340-
QueryReadRows->Collect(rowsCount > Max<i64>() ? Max<i64>() : static_cast<i64>(rowsCount));
340+
QueryReadRows->Collect(rowsCount);
341341
}
342342

343343
void TKqpCountersBase::ReportQueryMaxShardReplySize(ui64 replySize) {
344-
QueryMaxShardReplySize->Collect(replySize > Max<i64>() ? Max<i64>() : static_cast<i64>(replySize));
344+
QueryMaxShardReplySize->Collect(replySize);
345345
}
346346

347347
void TKqpCountersBase::ReportQueryMaxShardProgramSize(ui64 programSize) {
348-
QueryMaxShardProgramSize->Collect(programSize > Max<i64>() ? Max<i64>() : static_cast<i64>(programSize));
348+
QueryMaxShardProgramSize->Collect(programSize);
349349
}
350350

351351
void TKqpCountersBase::ReportResponseStatus(ui64 responseSize, Ydb::StatusIds::StatusCode ydbStatus) {

0 commit comments

Comments
 (0)