This commit is contained in:
c9s 2024-06-14 09:13:38 +00:00 committed by GitHub
commit cb0b6e88b4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -115,8 +115,11 @@ func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, s
} }
if !sentAny { if !sentAny {
log.Debugf("batch querying %T: %d/%d records are not sent", q.Type, listLen, listLen) // there are 2 reasons that records can not send
return // 1) duplicated record
// 2) out-of-range record
log.Debugf("batch querying %T: %d/%d records are not sent, continue to the next batch", q.Type, listLen, listLen)
continue
} }
} }
}() }()