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