15
15
use std:: sync:: Arc ;
16
16
17
17
use databend_common_catalog:: plan:: DataSourcePlan ;
18
+ use databend_common_catalog:: table:: Table ;
18
19
use databend_common_catalog:: table_args:: TableArgs ;
19
20
use databend_common_catalog:: table_context:: TableContext ;
20
21
use databend_common_exception:: ErrorCode ;
@@ -173,6 +174,10 @@ async fn get_time_travel_size(storage_prefix: &str, op: &Operator) -> Result<u64
173
174
}
174
175
175
176
async fn calc_tbl_size ( tbl : & FuseTable ) -> Result < ( u64 , u64 ) > {
177
+ info ! (
178
+ "fuse_time_travel_size start calc_tbl_size:{}" ,
179
+ tbl. get_table_info( ) . desc
180
+ ) ;
176
181
let operator = tbl. get_operator ( ) ;
177
182
let storage_prefix = tbl. get_storage_prefix ( ) ;
178
183
let start = std:: time:: Instant :: now ( ) ;
@@ -182,6 +187,7 @@ async fn calc_tbl_size(tbl: &FuseTable) -> Result<(u64, u64)> {
182
187
let latest_snapshot_size = match snapshot_location {
183
188
Some ( snapshot_location) => {
184
189
let start = std:: time:: Instant :: now ( ) ;
190
+ info ! ( "fuse_time_travel_size will read: {}" , snapshot_location) ;
185
191
let ( snapshot, _) = SnapshotsIO :: read_snapshot ( snapshot_location, operator) . await ?;
186
192
info ! ( "read_snapshot cost: {:?}" , start. elapsed( ) ) ;
187
193
snapshot. summary . compressed_byte_size + snapshot. summary . index_size
0 commit comments