diff options
| author | ssmike <[email protected]> | 2023-02-08 21:28:08 +0300 |
|---|---|---|
| committer | ssmike <[email protected]> | 2023-02-08 21:28:08 +0300 |
| commit | 24c4013da92b22c716790098cab1a1c3a1e657b6 (patch) | |
| tree | eaab1d513eb56c2f7e1353f030ff88a5568e617d | |
| parent | 135e3482a8a989c6eff6b5ae2f698103339b06d6 (diff) | |
fix error handler
| -rw-r--r-- | ydb/core/kqp/runtime/kqp_read_actor.cpp | 4 |
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); } |
