Fix: scroll offset

baking-bad · Mar 15, 2021 · 650b6c7 · 650b6c7
1 parent d30595f
commit 650b6c7
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/elastic/core/scroll.go b/internal/elastic/core/scroll.go
@@ -132,6 +132,9 @@ func (ctx *ScrollContext) Get(output interface{}) error {
 
 			length := int64(len(hits))
 			offset := ctx.Offset - count
+			if offset > length && length < ctx.ChunkSize {
+				break
+			}
 			if offset > 0 {
 				hits = hits[offset:]
 			}