This commit is contained in:
c9s 2024-09-19 09:41:09 +08:00 committed by GitHub
commit 4a106ac2e2
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
} }
} }
}() }()