diff --git a/writers/mixedbatchwriter/mixedbatchwriter.go b/writers/mixedbatchwriter/mixedbatchwriter.go index 49fb529d87..cca2a8b542 100644 --- a/writers/mixedbatchwriter/mixedbatchwriter.go +++ b/writers/mixedbatchwriter/mixedbatchwriter.go @@ -192,7 +192,7 @@ func (m *batchManager[A, T]) flush(ctx context.Context) error { if err != nil { return err } - m.batch = m.batch[:0] + m.batch = nil return nil } @@ -229,7 +229,7 @@ func (m *insertBatchManager) flush(ctx context.Context) error { } m.logger.Debug().Int("len", batchSize).Dur("duration", time.Since(start)).Msg("batch written successfully") - m.batch = m.batch[:0] + m.batch = nil m.curBatchSizeBytes = 0 return nil }