diff --git a/storage/eloq/ha_eloq.cc b/storage/eloq/ha_eloq.cc index 9f644d492fe..b8e30d3f40e 100644 --- a/storage/eloq/ha_eloq.cc +++ b/storage/eloq/ha_eloq.cc @@ -5639,7 +5639,8 @@ int ha_eloq::BulkUniqueCheck(size_t bulk_size) BatchReadTxRequest batch_read_req( &table_name, schema_version, batch_tuples, true, false, false, - coro_functors.first, coro_functors.second, my_tx->Txm(), 0, true); + coro_functors.first, coro_functors.second, my_tx->Txm(), true, 0, + true); my_tx->Txm()->Execute(&batch_read_req); batch_read_req.Wait(); @@ -6832,7 +6833,7 @@ int ha_eloq::SkIndexScanNext(uchar *table_record) BatchReadTxRequest batch_req(GetBaseTableNameFromTableSchema(), pk_key_version, sk_pk_scan_batch_, for_update, for_share, false, coro_functors.first, - coro_functors.second, txm); + coro_functors.second, txm, true); txm->Execute(&batch_req); batch_req.Wait(); @@ -9427,7 +9428,7 @@ int ha_eloq::batch_load_records(std::vector &vct_key) BatchReadTxRequest batch_req(GetBaseTableNameFromTableSchema(), pk_key_version, sk_pk_scan_batch_, for_update, for_share, false, coro_functors.first, - coro_functors.second, my_tx->Txm()); + coro_functors.second, my_tx->Txm(), true); TransactionExecution *txm= my_tx->Txm(); txm->Execute(&batch_req); batch_req.Wait(); @@ -9701,4 +9702,4 @@ maria_declare_plugin(eloq){ }, eloq_i_s_temp_table_info /* ELOQ_TEMP_TABLE_INFO */ - maria_declare_plugin_end; \ No newline at end of file + maria_declare_plugin_end; diff --git a/storage/eloq/tx_service b/storage/eloq/tx_service index 307387086a3..123d7f7ab1a 160000 --- a/storage/eloq/tx_service +++ b/storage/eloq/tx_service @@ -1 +1 @@ -Subproject commit 307387086a3e05d9da8c31dc6b818923361b076b +Subproject commit 123d7f7ab1af0d19e341ba590d9163994ab20838