Update batchwriter.go

bbernays · bbernays · commit 59d61d6e4c69 · 2026-04-27T14:10:03.000-05:00
diff --git a/writers/batchwriter/batchwriter.go b/writers/batchwriter/batchwriter.go
@@ -161,8 +161,9 @@ func (w *BatchWriter) worker(ctx context.Context, tableName string, ch <-chan *m
 				limit.AddSlice(add)
 			}
 			if len(toFlush) > 0 || rest != nil || limit.ReachedLimit() {
-				// flush current batch
-				send()
+				if limit.Rows() > 0 {
+					send()
+				}
 				ticker.Reset(w.batchTimeout)
 			}
 			for _, sliceToFlush := range toFlush {

Original file line number	Diff line number	Diff line change
`@@ -161,8 +161,9 @@ func (w BatchWriter) worker(ctx context.Context, tableName string, ch <-chan m`
`161`	`161`	`limit.AddSlice(add)`
`162`	`162`	`}`
`163`	`163`	`if len(toFlush) > 0 \|\| rest != nil \|\| limit.ReachedLimit() {`
`164`		`- // flush current batch`
`165`		`- send()`
	`164`	`+ if limit.Rows() > 0 {`
	`165`	`+ send()`
	`166`	`+ }`
`166`	`167`	`ticker.Reset(w.batchTimeout)`
`167`	`168`	`}`
`168`	`169`	`for _, sliceToFlush := range toFlush {`