diff --git a/CHANGES.md b/CHANGES.md
index dc7ab55bc..c364de207 100644
--- a/CHANGES.md
+++ b/CHANGES.md
@@ -16,6 +16,7 @@ Release Notes.
 - BanyanDB ui type error
 - Fix timer not released
 - BanyanDB ui misses fields when creating a group
+- Fix data duplicate writing
 
 ### Chores
 
diff --git a/banyand/measure/tstable.go b/banyand/measure/tstable.go
index b332d2f38..08765a5d1 100644
--- a/banyand/measure/tstable.go
+++ b/banyand/measure/tstable.go
@@ -154,6 +154,7 @@ func (t *tsTable) Get(key []byte, ts time.Time) ([]byte, error) {
 func (t *tsTable) Put(key []byte, val []byte, ts time.Time) error {
 	if t.encoderBuffer != nil {
 		t.writeToBuffer(key, val, ts)
+		return nil
 	}
 	if err := t.openBuffer(); err != nil {
 		return err
diff --git a/banyand/stream/tstable.go b/banyand/stream/tstable.go
index d1af0adb8..924f53f63 100644
--- a/banyand/stream/tstable.go
+++ b/banyand/stream/tstable.go
@@ -114,6 +114,7 @@ func (t *tsTable) Get(key []byte, ts time.Time) ([]byte, error) {
 func (t *tsTable) Put(key []byte, val []byte, ts time.Time) error {
 	if t.buffer != nil {
 		t.buffer.Write(key, val, ts)
+		return nil
 	}
 
 	if err := t.openBuffer(); err != nil {