@@ -115,6 +115,7 @@ void TColumnShardScan::HandleScan(NKqp::TEvKqpCompute::TEvScanDataAck::TPtr& ev)
115
115
116
116
void TColumnShardScan::HandleScan (NKqp::TEvKqpCompute::TEvScanPing::TPtr&) {
117
117
if (!AckReceivedInstant) {
118
+ AFL_WARN (NKikimrServices::TX_COLUMNSHARD_SCAN)(" event" , " ping_from_kqp" );
118
119
LastResultInstant = TMonotonic::Now ();
119
120
}
120
121
}
@@ -168,15 +169,14 @@ void TColumnShardScan::CheckHanging(const bool logging) const {
168
169
}
169
170
170
171
void TColumnShardScan::HandleScan (TEvents::TEvWakeup::TPtr& /* ev*/ ) {
171
- LOG_ERROR_S (*TlsActivationContext, NKikimrServices::TX_COLUMNSHARD_SCAN,
172
- " Scan " << ScanActorId << " guard execution timeout"
173
- << " txId: " << TxId << " scanId: " << ScanId << " gen: " << ScanGen << " tablet: " << TabletId);
174
-
172
+ AFL_ERROR (NKikimrServices::TX_COLUMNSHARD_SCAN)(" event" , " guard execution timeout" )(" scan_actor_id" , ScanActorId);
175
173
CheckHanging (true );
176
174
if (!AckReceivedInstant && TMonotonic::Now () >= GetComputeDeadline ()) {
175
+ AFL_ERROR (NKikimrServices::TX_COLUMNSHARD_SCAN)(" event" , " scan_termination" )(" deadline" , GetComputeDeadline ())(" timeout" , Timeout);
177
176
SendScanError (" ColumnShard scanner timeout: HAS_ACK=0" );
178
177
Finish (NColumnShard::TScanCounters::EStatusFinish::Deadline);
179
178
} else {
179
+ AFL_WARN (NKikimrServices::TX_COLUMNSHARD_SCAN)(" event" , " scan_continue" )(" deadline" , GetComputeDeadline ())(" timeout" , Timeout)(" now" , TMonotonic::Now ());
180
180
ScheduleWakeup (TMonotonic::Now () + Timeout / 5 );
181
181
}
182
182
}
@@ -401,7 +401,7 @@ void TColumnShardScan::SendScanError(const TString& reason) {
401
401
auto issue = NYql::YqlIssue ({}, NYql::TIssuesIds::KIKIMR_RESULT_UNAVAILABLE, msg);
402
402
NYql::IssueToMessage (issue, ev->Record .MutableIssues ()->Add ());
403
403
AFL_ERROR (NKikimrServices::TX_COLUMNSHARD_SCAN)(" event" , " scan_finish" )(" compute_actor_id" , ScanComputeActorId)(" stats" , Stats->ToJson ())(
404
- " iterator" , (ScanIterator ? ScanIterator->DebugString (false ) : " NO" ));
404
+ " iterator" , (ScanIterator ? ScanIterator->DebugString (false ) : " NO" ))( " reason " , reason) ;
405
405
406
406
Send (ScanComputeActorId, ev.Release ());
407
407
}
0 commit comments