fix: data is not appended with committed streams

goccy · Feb 5, 2024 · 2c3bc06 · 2c3bc06
1 parent 2d5db00
commit 2c3bc06
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/server/storage_handler.go b/server/storage_handler.go
@@ -517,6 +517,10 @@ func (s *storageWriteServer) appendRows(req *storagepb.AppendRowsRequest, msgDes
 			s.sendErrorMessage(stream, streamName, err)
 			return err
 		}
+		if err := tx.Commit(); err != nil {
+			s.sendErrorMessage(stream, streamName, err)
+			return err
+		}
 	} else {
 		status.rows = append(status.rows, data...)
 	}