From 0ff6d3a640b0e9e45eeec6f28e4b920b2d865eb2 Mon Sep 17 00:00:00 2001 From: "yuzhong.chen" Date: Mon, 30 Sep 2024 17:06:23 +0800 Subject: [PATCH] fix: rollbak send binlog coredump --- src/exec/fetcher_store.cpp | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/src/exec/fetcher_store.cpp b/src/exec/fetcher_store.cpp index 65e26e16..e17847bc 100755 --- a/src/exec/fetcher_store.cpp +++ b/src/exec/fetcher_store.cpp @@ -1087,16 +1087,16 @@ ErrorType FetcherStore::process_binlog_start(RuntimeState* state, pb::OpType op_ need_send_rollback = false; return; } - write_binlog_param.txn_id = state->txn_id; - write_binlog_param.log_id = log_id; - write_binlog_param.primary_region_id = client_conn->primary_region_id; - write_binlog_param.global_conn_id = client_conn->get_global_conn_id(); - write_binlog_param.username = client_conn->user_info->username; - write_binlog_param.ip = client_conn->ip; - write_binlog_param.client_conn = client_conn; - write_binlog_param.fetcher_store = this; binlog_ctx->set_start_ts(timestamp); } + write_binlog_param.txn_id = state->txn_id; + write_binlog_param.log_id = log_id; + write_binlog_param.primary_region_id = client_conn->primary_region_id; + write_binlog_param.global_conn_id = client_conn->get_global_conn_id(); + write_binlog_param.username = client_conn->user_info->username; + write_binlog_param.ip = client_conn->ip; + write_binlog_param.client_conn = client_conn; + write_binlog_param.fetcher_store = this; write_binlog_param.op_type = op_type; auto ret = binlog_ctx->write_binlog(&write_binlog_param); if (ret != E_OK) {