summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorssmike <[email protected]>2023-02-08 21:28:08 +0300
committerssmike <[email protected]>2023-02-08 21:28:08 +0300
commit24c4013da92b22c716790098cab1a1c3a1e657b6 (patch)
treeeaab1d513eb56c2f7e1353f030ff88a5568e617d
parent135e3482a8a989c6eff6b5ae2f698103339b06d6 (diff)
fix error handler
-rw-r--r--ydb/core/kqp/runtime/kqp_read_actor.cpp4
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/kqp/runtime/kqp_read_actor.cpp b/ydb/core/kqp/runtime/kqp_read_actor.cpp
index 80fe6d7a06e..dbc341393ac 100644
--- a/ydb/core/kqp/runtime/kqp_read_actor.cpp
+++ b/ydb/core/kqp/runtime/kqp_read_actor.cpp
@@ -717,7 +717,9 @@ public:
void HandleError(TEvPipeCache::TEvDeliveryProblem::TPtr& ev) {
auto& msg = *ev->Get();
- for (auto& read : ReadIdByTabletId[msg.TabletId]) {
+ TVector<ui32> reads;
+ reads.swap(ReadIdByTabletId[msg.TabletId]);
+ for (auto read : reads) {
CA_LOG_W("Got EvDeliveryProblem, TabletId: " << msg.TabletId << ", NotDelivered: " << msg.NotDelivered);
RetryRead(read);
}