diff --git a/sql/sql_insert.cc b/sql/sql_insert.cc index b0dd0ae5f24..de58b506940 100644 --- a/sql/sql_insert.cc +++ b/sql/sql_insert.cc @@ -2753,6 +2753,11 @@ bool Delayed_insert::handle_inserts(void) /* Remove all not used rows */ while ((row=rows.get())) { + if (table->s->blob_fields) + { + memcpy(table->record[0],row->record,table->s->reclength); + free_delayed_insert_blobs(table); + } delete row; thread_safe_increment(delayed_insert_errors,&LOCK_delayed_status); stacked_inserts--;