Merge pull request #267 from tomrussello/data-is-not-appended-with-co…

…mmitted-streams fix: data is not appended with committed streams
goccy · Feb 6, 2024 · 646ec96 · 646ec96
2 parents 2d5db00 + 1fa309d
commit 646ec96
Show file tree

Hide file tree

Showing 2 changed files with 214 additions and 158 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...)
 	}