We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents e994b0a + 1f2f371 commit e7bfbebCopy full SHA for e7bfbeb
pbm/restore/physical.go
@@ -2402,7 +2402,8 @@ func (r *PhysRestore) checkHB(file string) error {
2402
_, err := r.stg.FileStat(file)
2403
// compare with restore start if heartbeat files are yet to be created.
2404
// basically wait another hbFrameSec*2 sec for heartbeat files.
2405
- if errors.Is(err, storage.ErrNotExist) {
+ if errors.Is(err, storage.ErrNotExist) ||
2406
+ errors.Is(err, storage.ErrEmpty) {
2407
if r.startTS+hbFrameSec*2 < ts {
2408
return errors.Errorf("stuck, last beat ts: %d", r.startTS)
2409
}
0 commit comments