Skip to content

Commit fb124d5

Browse files
committed
more FailedZeroCheckpoint triggers
1 parent e1dbd5e commit fb124d5

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

ydb/core/fq/libs/checkpointing/checkpoint_coordinator.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -390,6 +390,7 @@ void TCheckpointCoordinator::Handle(const TEvCheckpointStorage::TEvCreateCheckpo
390390
if (issues) {
391391
CC_LOG_E("[" << checkpointId << "] StorageError: can't create checkpoint: " << issues.ToOneLineString());
392392
PendingCheckpoints.erase(checkpointId);
393+
FailedZeroCheckpoint = InitingZeroCheckpoint;
393394
UpdateInProgressMetric();
394395
++*Metrics.FailedToCreate;
395396
++*Metrics.StorageError;
@@ -496,6 +497,7 @@ void TCheckpointCoordinator::Handle(const TEvCheckpointStorage::TEvSetCheckpoint
496497
CC_LOG_E("[" << checkpointId << "] StorageError: can't change checkpoint status to 'PendingCommit': " << issues.ToString());
497498
++*Metrics.StorageError;
498499
PendingCheckpoints.erase(it);
500+
FailedZeroCheckpoint = InitingZeroCheckpoint;
499501
return;
500502
}
501503

@@ -573,6 +575,7 @@ void TCheckpointCoordinator::Handle(const TEvCheckpointStorage::TEvAbortCheckpoi
573575
++*Metrics.Aborted;
574576
}
575577
PendingCheckpoints.erase(checkpointId);
578+
FailedZeroCheckpoint = InitingZeroCheckpoint;
576579
PendingCommitCheckpoints.erase(checkpointId);
577580
UpdateInProgressMetric();
578581
}

0 commit comments

Comments
 (0)