diff --git a/.bzrignore b/.bzrignore index eff6aeb4967b93e86a9eb23ba6f0eb2aa0ceed9c..763c926eb1b46932924bcc8a42a925a9db139e0d 100644 --- a/.bzrignore +++ b/.bzrignore @@ -425,3 +425,7 @@ mysql-test/var/slave-data/mysql-bin.012 mysql-test/var/slave-data/mysql-bin.013 mysql-test/var/slave-data/mysql-bin.014 mysql-test/var/slave-data/mysql-bin.index +BitKeeper/tmp/applied.list +BitKeeper/tmp/backup.list +BitKeeper/tmp/backup.sfio +BitKeeper/tmp/sfile.list diff --git a/BitKeeper/etc/logging_ok b/BitKeeper/etc/logging_ok index fb7d3b9d9c5ada191dbb62609a3a07f17eb3229c..95b2857507db60fc080a51f5b15477cc7c48aef1 100644 --- a/BitKeeper/etc/logging_ok +++ b/BitKeeper/etc/logging_ok @@ -1,5 +1,5 @@ jani@prima.mysql.com +jani@prima.mysql.fi sasha@mysql.sashanet.com sasha@work.mysql.com serg@serg.mysql.com -jani@prima.mysql.fi diff --git a/sql/slave.cc b/sql/slave.cc index ece6341ca16a2d72739026219da2a2567c190cbe..b68dc8023aee5328e71eb749351db78574f484b4 100644 --- a/sql/slave.cc +++ b/sql/slave.cc @@ -874,6 +874,9 @@ static int exec_event(THD* thd, NET* net, MASTER_INFO* mi, int event_len) if(mysql_load(thd, &ex, &tables, fields, handle_dup, 1, TL_WRITE)) thd->query_error = 1; + if(thd->cuted_fields) + sql_print_error("Slave: load data infile at position %d in log \ +'%s' produced %d warning(s)", glob_mi.pos, RPL_LOG_NAME, thd->cuted_fields ); net->pkt_nr = thd->net.pkt_nr; } else // we will just ask the master to send us /dev/null if we do not want to diff --git a/sql/sql_load.cc b/sql/sql_load.cc index 7c2d77ce3fc77dee92dff8eefae8d90148014a70..b73f689322563a1b84c2233261adaafbe81ff548 100644 --- a/sql/sql_load.cc +++ b/sql/sql_load.cc @@ -241,7 +241,9 @@ int mysql_load(THD *thd,sql_exchange *ex,TABLE_LIST *table_list, sprintf(name,ER(ER_LOAD_INFO),info.records,info.deleted, info.records-info.copied,thd->cuted_fields); send_ok(&thd->net,info.copied+info.deleted,0L,name); - mysql_update_log.write(thd,thd->query,thd->query_length); + // on the slave thd->query is never initialized + if(!thd->slave_thread) + mysql_update_log.write(thd,thd->query,thd->query_length); if (!table->file->has_transactions()) thd->options|=OPTION_STATUS_NO_TRANS_UPDATE;