Fix data duplicate writing (#304)

apache · Jul 19, 2023 · c001e15 · c001e15
1 parent 056624a
commit c001e15
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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 {