Merge ed8d66cdef into 5098c3ac35

batch: fix time range query
when sentAny == false, continue to the next batch
2024-11-10 09:11:55 +00:00 · 2024-06-14 09:13:38 +00:00 · 2024-01-08 17:58:32 +08:00
1 changed files with 5 additions and 2 deletions
--- 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
 			}
 		}
 	}()
Author	SHA1	Message	Date
c9s	cb0b6e88b4	Merge `ed8d66cdef` into `5098c3ac35`	2024-06-14 09:13:38 +00:00
c9s	ed8d66cdef	batch: fix time range query when sentAny == false, continue to the next batch	2024-01-08 17:58:32 +08:00