From d00bfc6b9cb89eefa8b99cc26e6b8e1d16687037 Mon Sep 17 00:00:00 2001
From: Aditya Ujeniya <adityauj@gmail.com>
Date: Tue, 27 May 2025 14:21:10 +0200
Subject: [PATCH] Fix to avro reader

---
 internal/memorystore/checkpoint.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/internal/memorystore/checkpoint.go b/internal/memorystore/checkpoint.go
index ff2cb5c..7c7d467 100644
--- a/internal/memorystore/checkpoint.go
+++ b/internal/memorystore/checkpoint.go
@@ -536,10 +536,11 @@ func (l *Level) loadAvroFile(m *MemoryStore, f *os.File, from int64) error {
 }
 
 func (l *Level) createBuffer(m *MemoryStore, metricName string, floatArray util.FloatArray, from int64, resolution int64) error {
+	n := len(floatArray)
 	b := &buffer{
 		frequency: resolution,
 		start:     from,
-		data:      floatArray,
+		data:      floatArray[0:n:n],
 		prev:      nil,
 		next:      nil,
 		archived:  true,
@@ -570,6 +571,8 @@ func (l *Level) createBuffer(m *MemoryStore, metricName string, floatArray util.
 			for range missingCount {
 				prev.data = append(prev.data, util.NaN)
 			}
+
+			prev.data = prev.data[0:len(prev.data):len(prev.data)]
 		}
 	}
 	l.metrics[minfo.Offset] = b