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