From ed8d66cdef3e2872891207876caa99419a4afd49 Mon Sep 17 00:00:00 2001 From: c9s Date: Fri, 17 Nov 2023 10:05:54 +0800 Subject: [PATCH] batch: fix time range query when sentAny == false, continue to the next batch --- pkg/exchange/batch/time_range_query.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/exchange/batch/time_range_query.go b/pkg/exchange/batch/time_range_query.go index 7b8490c59..d7fd2e78c 100644 --- a/pkg/exchange/batch/time_range_query.go +++ b/pkg/exchange/batch/time_range_query.go @@ -115,8 +115,11 @@ func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, s } if !sentAny { - log.Debugf("batch querying %T: %d/%d records are not sent", q.Type, listLen, listLen) - return + // there are 2 reasons that records can not send + // 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 } } }()