Commit fc390db4 authored by unknown's avatar unknown

Bug #26783 replication status unknown after cluster or mysqld failure

- part one, extend apply_status table

parent 90319379
...@@ -756,6 +756,9 @@ static int ndbcluster_create_ndb_apply_status_table(THD *thd) ...@@ -756,6 +756,9 @@ static int ndbcluster_create_ndb_apply_status_table(THD *thd)
NDB_REP_DB "." NDB_APPLY_TABLE NDB_REP_DB "." NDB_APPLY_TABLE
" ( server_id INT UNSIGNED NOT NULL," " ( server_id INT UNSIGNED NOT NULL,"
" epoch BIGINT UNSIGNED NOT NULL, " " epoch BIGINT UNSIGNED NOT NULL, "
" log_name VARCHAR(255) BINARY NOT NULL, "
" start_pos BIGINT UNSIGNED NOT NULL, "
" end_pos BIGINT UNSIGNED NOT NULL, "
" PRIMARY KEY USING HASH (server_id) ) ENGINE=NDB"); " PRIMARY KEY USING HASH (server_id) ) ENGINE=NDB");
run_query(thd, buf, end, TRUE, TRUE); run_query(thd, buf, end, TRUE, TRUE);
...@@ -3800,6 +3803,9 @@ pthread_handler_t ndb_binlog_thread_func(void *arg) ...@@ -3800,6 +3803,9 @@ pthread_handler_t ndb_binlog_thread_func(void *arg)
bzero(table->record[0], table->s->null_bytes); bzero(table->record[0], table->s->null_bytes);
table->field[0]->store((longlong)::server_id); table->field[0]->store((longlong)::server_id);
table->field[1]->store((longlong)gci); table->field[1]->store((longlong)gci);
table->field[2]->store("", 0, &my_charset_bin);
table->field[3]->store((longlong)0);
table->field[4]->store((longlong)0);
trans.write_row(::server_id, trans.write_row(::server_id,
injector::transaction::table(table, TRUE), injector::transaction::table(table, TRUE),
&table->s->all_set, table->s->fields, &table->s->all_set, table->s->fields,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment