refactor: remove timeout from snapshot hint refresh process (#17532)

Author: dantengsky

src/query/storages/fuse/src/fuse_table.rs

@@ -25,7 +25,6 @@ use std::time::Instant;
 use async_channel::Receiver;
 use chrono::Duration;
 use chrono::TimeDelta;
-use databend_common_base::base::tokio;
 use databend_common_base::runtime::GlobalIORuntime;
 use databend_common_catalog::catalog::StorageDescription;
 use databend_common_catalog::plan::DataSourcePlan;
@@ -150,8 +149,6 @@ pub struct FuseTable {
 type PartInfoReceiver = Option<Receiver<Result<PartInfoPtr>>>;
 
 // default schema refreshing timeout is 5 seconds.
-const DEFAULT_SCHEMA_REFRESHING_TIMEOUT: std::time::Duration = std::time::Duration::from_secs(5);
-
 impl FuseTable {
     pub fn try_create(table_info: TableInfo) -> Result<Box<dyn Table>> {
         Ok(Self::do_create_table_ext(table_info, false)?)
@@ -485,7 +482,6 @@ impl FuseTable {
     fn refresh_schema_from_hint(
         operator: &Operator,
         storage_prefix: &str,
-        table_description: &str,
     ) -> Result<Option<(SnapshotHint, TableSchema)>> {
         let refresh_task = async {
             let begin_load_hint = Instant::now();
@@ -529,24 +525,7 @@ impl FuseTable {
             }
         };
 
-        let refresh_task_with_timeout = async {
-            tokio::time::timeout(DEFAULT_SCHEMA_REFRESHING_TIMEOUT, refresh_task)
-                .await
-                .map_err(|_e| {
-                    ErrorCode::RefreshTableInfoFailure(format!(
-                        "failed to refresh table info {} in time",
-                        table_description
-                    ))
-                })
-                .map_err(|e| {
-                    ErrorCode::RefreshTableInfoFailure(format!(
-                        "failed to refresh table info {} : {}",
-                        table_description, e
-                    ))
-                })?
-        };
-
-        GlobalIORuntime::instance().block_on(refresh_task_with_timeout)
+        GlobalIORuntime::instance().block_on(refresh_task)
     }
 
     fn refresh_table_info(
@@ -571,8 +550,7 @@ impl FuseTable {
             table_info.ident
         );
 
-        let snapshot_hint =
-            Self::refresh_schema_from_hint(operator, storage_prefix, &table_info.desc)?;
+        let snapshot_hint = Self::refresh_schema_from_hint(operator, storage_prefix)?;
 
         info!(
             "extracted snapshot location [{:?}] of table {}, with id {:?} from the last snapshot hint file.",