@@ -161,9 +161,15 @@ void TColumnShardScan::CheckHanging(const bool logging) const {
161
161
" scan_actor_id" , ScanActorId)(" tx_id" , TxId)(" scan_id" , ScanId)(" gen" , ScanGen)(" tablet" , TabletId)(
162
162
" debug" , ScanIterator ? ScanIterator->DebugString () : Default<TString>())(" last" , LastResultInstant);
163
163
}
164
- AFL_VERIFY (!!FinishInstant || !ScanIterator || !ChunksLimiter.HasMore () || ScanCountersPool.InWaiting ())(" scan_actor_id" , ScanActorId)(" tx_id" , TxId)(" scan_id" , ScanId)(
165
- " gen" , ScanGen)(" tablet" , TabletId)(" debug" , ScanIterator->DebugString ())(
166
- " counters" , ScanCountersPool.DebugString ());
164
+ const bool ok = !!FinishInstant || !ScanIterator || !ChunksLimiter.HasMore () || ScanCountersPool.InWaiting ();
165
+ AFL_VERIFY_DEBUG (ok)
166
+ (" scan_actor_id" , ScanActorId)(" tx_id" , TxId)(" scan_id" , ScanId)(" gen" , ScanGen)(" tablet" , TabletId)(" debug" , ScanIterator->DebugString ())(
167
+ " counters" , ScanCountersPool.DebugString ());
168
+ if (!ok) {
169
+ AFL_CRIT (NKikimrServices::TX_COLUMNSHARD_SCAN)(" error" , " CheckHanging" )(" scan_actor_id" , ScanActorId)(" tx_id" , TxId)(" scan_id" , ScanId)(" gen" , ScanGen)(
170
+ " tablet" , TabletId)(" debug" , ScanIterator->DebugString ())(" counters" , ScanCountersPool.DebugString ());
171
+ ScanCountersPool.OnHangingRequestDetected ();
172
+ }
167
173
}
168
174
169
175
void TColumnShardScan::HandleScan (TEvents::TEvWakeup::TPtr& /* ev*/ ) {
0 commit comments