diff --git a/be/src/olap/schema_change.cpp b/be/src/olap/schema_change.cpp index 67d9ca75e1b46d..c947ceb904c8ad 100644 --- a/be/src/olap/schema_change.cpp +++ b/be/src/olap/schema_change.cpp @@ -1425,6 +1425,7 @@ OLAPStatus SchemaChangeHandler::schema_version_convert( writer_context.rowset_path_prefix = new_tablet->tablet_path(); writer_context.tablet_schema = &(new_tablet->tablet_schema()); writer_context.rowset_state = PREPARED; + writer_context.txn_id = (*base_rowset)->txn_id(); writer_context.load_id.set_hi((*base_rowset)->load_id().hi()); writer_context.load_id.set_lo((*base_rowset)->load_id().lo()); RowsetWriterSharedPtr rowset_writer(new AlphaRowsetWriter()); diff --git a/be/src/olap/task/engine_publish_version_task.cpp b/be/src/olap/task/engine_publish_version_task.cpp index de3d36202de4f9..01c7a82230bfd9 100644 --- a/be/src/olap/task/engine_publish_version_task.cpp +++ b/be/src/olap/task/engine_publish_version_task.cpp @@ -32,7 +32,7 @@ EnginePublishVersionTask::EnginePublishVersionTask(TPublishVersionRequest& publi OLAPStatus EnginePublishVersionTask::finish() { LOG(INFO) << "begin to process publish version. transaction_id=" - << _publish_version_req.transaction_id; + << _publish_version_req.transaction_id; int64_t transaction_id = _publish_version_req.transaction_id; OLAPStatus res = OLAP_SUCCESS;