diff --git a/server/storage_handler.go b/server/storage_handler.go
index 1503b10ac..88ed3e87d 100644
--- 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...)
 	}