diff --git a/src/query/service/src/interpreters/interpreter_table_recluster.rs b/src/query/service/src/interpreters/interpreter_table_recluster.rs index c1ca2cf9e2479..d78c9622c96ae 100644 --- a/src/query/service/src/interpreters/interpreter_table_recluster.rs +++ b/src/query/service/src/interpreters/interpreter_table_recluster.rs @@ -159,7 +159,7 @@ impl Interpreter for ReclusterTableInterpreter { } } - let elapsed_time = SystemTime::now().duration_since(start).unwrap(); + let elapsed_time = SystemTime::now().duration_since(start).unwrap_or_default(); times += 1; // Status. { diff --git a/tests/sqllogictests/suites/base/09_fuse_engine/09_0037_target_build_merge_into_without_distributed_enable.test b/tests/sqllogictests/suites/base/09_fuse_engine/09_0037_target_build_merge_into_without_distributed_enable.test index 93f9bac6de5a7..9af366c7ec934 100644 --- a/tests/sqllogictests/suites/base/09_fuse_engine/09_0037_target_build_merge_into_without_distributed_enable.test +++ b/tests/sqllogictests/suites/base/09_fuse_engine/09_0037_target_build_merge_into_without_distributed_enable.test @@ -199,13 +199,11 @@ merge into t_17800 using t1_17800 on t_17800.a=t1_17800.a when matched then upda ---- 17 33 -query II -select segment_count, row_count from fuse_snapshot('db','t_17800') limit 4; +query B +select abs(stats_row_count - actual_row_count) * 10 < actual_row_count from system.statistics where database = 'db' and table = 't_17800'; ---- -1 117 -1 117 -2 117 -1 100 +1 +1 statement ok CREATE OR REPLACE TABLE t1(id string, raw_data variant, add_time timestamp, action string);