fix: recluster transient table failed with TransactionTimeout (#17868)

Author: SkyFan2002

src/query/catalog/src/table_context.rs

@@ -354,6 +354,8 @@ pub trait TableContext: Send + Sync {
         previous_snapshot: Option<Arc<TableSnapshot>>,
     ) -> Result<TableMetaTimestamps>;
 
+    fn clear_table_meta_timestamps_cache(&self);
+
     fn get_read_block_thresholds(&self) -> BlockThresholds;
     fn set_read_block_thresholds(&self, _thresholds: BlockThresholds);
 

src/query/service/src/interpreters/interpreter_table_recluster.rs

@@ -192,6 +192,7 @@ impl ReclusterTableInterpreter {
         push_downs: &mut Option<PushDownInfo>,
         hilbert_info: &mut Option<HilbertBuildInfo>,
     ) -> Result<bool> {
+        self.ctx.clear_table_meta_timestamps_cache();
         let start = SystemTime::now();
         let settings = self.ctx.get_settings();
 

src/query/service/src/sessions/query_ctx.rs

@@ -1532,6 +1532,11 @@ impl TableContext for QueryContext {
         }
     }
 
+    fn clear_table_meta_timestamps_cache(&self) {
+        let cache = self.shared.get_table_meta_timestamps();
+        cache.lock().clear();
+    }
+
     fn get_read_block_thresholds(&self) -> BlockThresholds {
         *self.block_threshold.read()
     }

src/query/service/tests/it/sql/exec/get_table_bind_test.rs

@@ -1006,6 +1006,10 @@ impl TableContext for CtxDelegation {
         self.ctx.get_table_meta_timestamps(table, previous_snapshot)
     }
 
+    fn clear_table_meta_timestamps_cache(&self) {
+        self.ctx.clear_table_meta_timestamps_cache();
+    }
+
     fn get_temp_table_prefix(&self) -> Result<String> {
         todo!()
     }

src/query/service/tests/it/storages/fuse/operations/commit.rs

@@ -895,6 +895,10 @@ impl TableContext for CtxDelegation {
     ) -> Result<TableMetaTimestamps> {
         self.ctx.get_table_meta_timestamps(table, previous_snapshot)
     }
+
+    fn clear_table_meta_timestamps_cache(&self) {
+        self.ctx.clear_table_meta_timestamps_cache();
+    }
 }
 
 #[derive(Clone, Debug)]

tests/sqllogictests/suites/base/09_fuse_engine/09_0047_issue_17867.sql

@@ -0,0 +1,20 @@
+statement ok
+create or replace transient table t (c int) cluster by (c);
+
+statement ok
+insert into t values(1), (3), (5);
+
+statement ok
+insert into t values(2), (7), (9);
+
+statement ok
+alter table t recluster final;
+
+statement ok
+insert into t values(1), (3), (5);
+
+statement ok
+insert into t values(2), (7), (9);
+
+statement ok
+alter table t recluster final;