diff --git a/src/meta-client/src/client/procedure.rs b/src/meta-client/src/client/procedure.rs index f854193327..b6eb07e686 100644 --- a/src/meta-client/src/client/procedure.rs +++ b/src/meta-client/src/client/procedure.rs @@ -300,11 +300,12 @@ impl Inner { ) .await?; + let stats = resp.stats.unwrap_or_default(); Ok(MetaGcResponse { - processed_regions: resp.processed_regions, - need_retry_regions: resp.need_retry_regions, - deleted_files: resp.deleted_files, - deleted_indexes: resp.deleted_indexes, + processed_regions: stats.processed_regions, + need_retry_regions: stats.need_retry_regions, + deleted_files: stats.deleted_files, + deleted_indexes: stats.deleted_indexes, }) } @@ -335,11 +336,12 @@ impl Inner { ) .await?; + let stats = resp.stats.unwrap_or_default(); Ok(MetaGcResponse { - processed_regions: resp.processed_regions, - need_retry_regions: resp.need_retry_regions, - deleted_files: resp.deleted_files, - deleted_indexes: resp.deleted_indexes, + processed_regions: stats.processed_regions, + need_retry_regions: stats.need_retry_regions, + deleted_files: stats.deleted_files, + deleted_indexes: stats.deleted_indexes, }) } diff --git a/src/meta-srv/src/service/procedure.rs b/src/meta-srv/src/service/procedure.rs index 0754e7b777..60f74df43a 100644 --- a/src/meta-srv/src/service/procedure.rs +++ b/src/meta-srv/src/service/procedure.rs @@ -17,7 +17,7 @@ use std::time::Duration; use api::v1::meta::reconcile_request::Target; use api::v1::meta::{ DdlTaskRequest as PbDdlTaskRequest, DdlTaskResponse as PbDdlTaskResponse, GcRegionsRequest, - GcRegionsResponse, GcTableRequest, GcTableResponse, MigrateRegionRequest, + GcRegionsResponse, GcStats, GcTableRequest, GcTableResponse, MigrateRegionRequest, MigrateRegionResponse, ProcedureDetailRequest, ProcedureDetailResponse, ProcedureStateResponse, QueryProcedureRequest, ReconcileCatalog, ReconcileDatabase, ReconcileRequest, ReconcileResponse, ReconcileTable, ResolveStrategy, procedure_service_server, @@ -422,20 +422,24 @@ fn gc_report_to_response( fn gc_response_to_regions_pb(resp: GcResponse) -> GcRegionsResponse { GcRegionsResponse { - processed_regions: resp.processed_regions, - need_retry_regions: resp.need_retry_regions, - deleted_files: resp.deleted_files, - deleted_indexes: resp.deleted_indexes, + stats: Some(GcStats { + processed_regions: resp.processed_regions, + need_retry_regions: resp.need_retry_regions, + deleted_files: resp.deleted_files, + deleted_indexes: resp.deleted_indexes, + }), ..Default::default() } } fn gc_response_to_table_pb(resp: GcResponse) -> GcTableResponse { GcTableResponse { - processed_regions: resp.processed_regions, - need_retry_regions: resp.need_retry_regions, - deleted_files: resp.deleted_files, - deleted_indexes: resp.deleted_indexes, + stats: Some(GcStats { + processed_regions: resp.processed_regions, + need_retry_regions: resp.need_retry_regions, + deleted_files: resp.deleted_files, + deleted_indexes: resp.deleted_indexes, + }), ..Default::default() } }