From 1fc9dcf9bfd470d5ff7e4b72ab2e28337b985bf4 Mon Sep 17 00:00:00 2001 From: jeremyhi Date: Sat, 19 Sep 2026 19:44:37 +0800 Subject: [PATCH] fix: allow default S3 endpoint in packed restore test Signed-off-by: jeremyhi --- tests-integration/tests/export_logical_tables.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/tests-integration/tests/export_logical_tables.rs b/tests-integration/tests/export_logical_tables.rs index f98470b1450..310d475ccbe 100644 --- a/tests-integration/tests/export_logical_tables.rs +++ b/tests-integration/tests/export_logical_tables.rs @@ -908,7 +908,7 @@ async fn packed_copy_standalone_heterogeneous_streams() { "packed-reader/{}/", destination.path().file_name().unwrap().to_str().unwrap() ); - let connection = std::collections::HashMap::from([ + let mut connection = std::collections::HashMap::from([ ( "access_key_id".into(), std::env::var("GT_S3_ACCESS_KEY_ID").unwrap(), @@ -918,11 +918,10 @@ async fn packed_copy_standalone_heterogeneous_streams() { std::env::var("GT_S3_ACCESS_KEY").unwrap(), ), ("region".into(), std::env::var("GT_S3_REGION").unwrap()), - ( - "endpoint".into(), - std::env::var("GT_S3_ENDPOINT_URL").unwrap(), - ), ]); + if let Ok(endpoint) = std::env::var("GT_S3_ENDPOINT_URL") { + connection.insert("endpoint".into(), endpoint); + } let location = format!("s3://{bucket}/{prefix}"); let store = common_datasource::object_store::build_backend( &location,