Skip to content

Commit a925034

Browse files
authored
fix request shard count sensor (#11962)
1 parent 2bc34d4 commit a925034

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

ydb/core/tx/tx_proxy/rpc_long_tx.cpp

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,10 +96,11 @@ class TLongTxWriteBase: public TActorBootstrapped<TLongTxWriteImpl>,
9696
accessor.reset();
9797

9898
const auto& splittedData = shardsSplitter->GetSplitData();
99+
const auto& shardsInRequest = splittedData.GetShardRequestsCount();
99100
InternalController =
100-
std::make_shared<NEvWrite::TWritersController>(splittedData.GetShardRequestsCount(), this->SelfId(), LongTxId, NoTxWrite);
101+
std::make_shared<NEvWrite::TWritersController>(shardsInRequest, this->SelfId(), LongTxId, NoTxWrite);
101102

102-
InternalController->GetCounters()->OnSplitByShards(splittedData.GetShardsCount());
103+
InternalController->GetCounters()->OnSplitByShards(shardsInRequest);
103104
ui32 sumBytes = 0;
104105
ui32 rowsCount = 0;
105106
ui32 writeIdx = 0;

0 commit comments

Comments
 (0)