diff --git a/pkg/logstructured/sqllog/sql.go b/pkg/logstructured/sqllog/sql.go index 4fe0e41e..a6105507 100644 --- a/pkg/logstructured/sqllog/sql.go +++ b/pkg/logstructured/sqllog/sql.go @@ -432,7 +432,9 @@ func (s *SQLLog) poll(result chan interface{}, pollStart int64) { rows, err := s.d.After(s.ctx, "%", s.currentRev, pollBatchSize) if err != nil { - logrus.Errorf("fail to list latest changes: %v", err) + if !errors.Is(err, context.Canceled) { + logrus.Errorf("fail to list latest changes: %v", err) + } continue }