Add final logging for aborted checkpoint

yumkam · yumkam · commit 3bba90f1f6bb · 2024-11-25T11:47:10.000+03:00
diff --git a/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp b/ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp
@@ -467,6 +467,7 @@ void TCheckpointCoordinator::Handle(const NYql::NDq::TEvDqCompute::TEvSaveTaskSt
     }
     if (checkpoint.GotAllAcknowledges()) {
         if (checkpoint.GetStats().Aborted) {
+            CC_LOG_E("[" << checkpointId << "] Got all acks for aborted checkpoint, aborting in storage");
             CheckpointingSnapshotRotationIndex = CheckpointingSnapshotRotationPeriod;  // Next checkpoint is snapshot.
             Send(StorageProxy, new TEvCheckpointStorage::TEvAbortCheckpointRequest(CoordinatorId, checkpointId, "Can't save node state"), IEventHandle::FlagTrackDelivery);
         } else {

Original file line number	Diff line number	Diff line change
`@@ -467,6 +467,7 @@ void TCheckpointCoordinator::Handle(const NYql::NDq::TEvDqCompute::TEvSaveTaskSt`
`467`	`467`	`}`
`468`	`468`	`if (checkpoint.GotAllAcknowledges()) {`
`469`	`469`	`if (checkpoint.GetStats().Aborted) {`
	`470`	`+ CC_LOG_E("[" << checkpointId << "] Got all acks for aborted checkpoint, aborting in storage");`
`470`	`471`	`CheckpointingSnapshotRotationIndex = CheckpointingSnapshotRotationPeriod; // Next checkpoint is snapshot.`
`471`	`472`	`Send(StorageProxy, new TEvCheckpointStorage::TEvAbortCheckpointRequest(CoordinatorId, checkpointId, "Can't save node state"), IEventHandle::FlagTrackDelivery);`
`472`	`473`	`} else {`