batch: fix time range query

c9s · c9s · commit e3168e74f73d · 2023-11-17T17:19:25.000+08:00
when sentAny == false, continue to the next batch
diff --git 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
 			}
 		}
 	}()

Original file line number	Diff line number	Diff line change
`@@ -115,8 +115,11 @@ func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, s`
`115`	`115`	`}`
`116`	`116`
`117`	`117`	`if !sentAny {`
`118`		`- log.Debugf("batch querying %T: %d/%d records are not sent", q.Type, listLen, listLen)`
`119`		`- return`
	`118`	`+ // there are 2 reasons that records can not send`
	`119`	`+ // 1) duplicated record`
	`120`	`+ // 2) out-of-range record`
	`121`	`+ log.Debugf("batch querying %T: %d/%d records are not sent, continue to the next batch", q.Type, listLen, listLen)`
	`122`	`+ continue`
`120`	`123`	`}`
`121`	`124`	`}`
`122`	`125`	`}()`