In Vitess 2.2, we are adding preliminary support for Row Based Replication. This document explains how we are managing it and how it affects various Vitess features.
See the Vites and Replication document for an introduction on various types of replication and how it affects Vitess.
With Row Based replication, a more compact binary version of the rows affected
are sent through the replication stream, instead of the SQL statements. The
slaves then do not spend any time parsing the SQL, or performing any complex SQL
where clauses). They can just apply the new rows directly.
A few binlog events are used:
Table Map event: describes a table that is affected by the next events. Contains the database and table name, the number of columns, and the Type for each column. It does not contain the individual column names, nor the flags for each column (so it is impossible to differentiate signed vs unsigned integers for instance).
Write Rows: equivalent of Insert.
Update Rows: change the values of some rows.
Delete Rows: delete the provided rows.
binlog-row-image option can
be used to control which rows are used to identify the columns for the Update
and Delete Rows events. The default setting for that option is to log all columns.
Vitess uses the Replication Stream in a number of places. This part explains how we can use RBR for these.
This is enabled by the
watch_replication_stream option, and is used by Update
Stream. It only cares about the GTIDs for the events, so it is unaffected by the use of RBR.
Note: the current vttablet also reloads the schema when it sees a DDL in the stream. See below for more information on this.
The current implementation uses comments in the original SQL (in SQR) to provide the primary key of the column that is being changed.
We are changing this to also parse the RBR events, and extract the primary key value.
Note: this means we need accurate schema information. See below.
This is used during horizontal and vertical resharding, to keep source and destination shards up to date.
We need to transform the RBR events into SQL statements, filter them based either on keyspace_id (horizontal resharding) or table name (vertical resharding), and apply them.
For horizontal splits, we need to understand the VSchema to be able to find the primary VIndex used for sharding.
Note: this again means we need accurate schema information. We could do one of two things:
Send all statements to all destination shards, and let them do the filtering. They can have accurate schema information if they receive and apply all schema changes through Filtered Replication.
Have the filtering be done on the stream server side, and assume the schema doesn't change in incompatible ways. As this is simpler for now, that's the option we're going with.
A lot of the work to interpret RBR events correctly requires knowledge of the table's schema. However, this introduces the possibility of inconsistencies during schema changes: the current schema for a table might be newer than the schema an older replication stream event was using.
For the short term, Vitess will not deal very gracefully with this scenario: we will only support the case where the current schema for a table has exactly the same columns as all events in the binlog, plus some other optional columns that are then unused. That way, it is possible to add columns to tables without breaking anything.
Note if the main use case is Filtered Replicaiton for resharding, this limitation only exists while the resharding process is running. It is somewhat easy to not change the schema at the same time as resharding is on-going.
When using RBR, Schema Swap becomes useless, as replication between hosts with different schemas will most likely break. This is however an existing limitation that is already known and handled by MySQL DBAs.
Vitess at this point does not provide an integrated way of applying involved schema changes through RBR. A number of external tools however already exist to handle this case, like gh-ost.
We have future plans to:
Integrate with a tool like gh-ost to provide a seamless schema change story.
Maintain a history of the schema changes that happen on all shards, so events can be parsed correctly in all cases.
Update Stream can be changed to contain both old and new values of the rows being changed. Again the values will depend on the schema. We will also make this feature optional, so if the client is using this for Primary Key based cache invalidation for instance, no extra unneeded data is sent.
This can be used to re-populate a cache with Update Stream, instead of invalidating it, by putting the new values directly in there.
Then, using this in conjunction with
binlog-row-image would help provide a
feature-complete way of always getting all changes on rows. It would also help
handle Update Stream corner cases that replay events during resharding, when
switching traffic from old to new shards.
A lot of the work done by vttablet now is to find the Primary Key of the modified rows, to rewrite the queries in an efficient way and tag each statement with the Primary Key. None of this may be necessary with RBR.
We plan to eventually add a
rbr_mode flag to vttablet to disable all the things it can
skip if RBR is used.