From 727fa674fe63825ae7ba7204386017050b0dee6b Mon Sep 17 00:00:00 2001 From: wangwq10 Date: Sun, 20 Jul 2025 20:58:59 +0800 Subject: [PATCH] fix: add break to skip dead loop in "transaction does not exist" --- pkg/ccr/base/spec.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/pkg/ccr/base/spec.go b/pkg/ccr/base/spec.go index 0eb5f895..c5908414 100644 --- a/pkg/ccr/base/spec.go +++ b/pkg/ccr/base/spec.go @@ -1131,6 +1131,9 @@ func (s *Spec) WaitTransactionDone(txnId int64) { for { if err := s.waitTransactionDone(txnId); err != nil { log.Errorf("wait transaction done failed, err +%v", err) + if strings.Contains(err.Error(), "does not exist") { + break + } time.Sleep(time.Second) } else { break