diff --git a/src/frontend/src/tests/instance_test.rs b/src/frontend/src/tests/instance_test.rs index a57242d74b..5d1551e66e 100644 --- a/src/frontend/src/tests/instance_test.rs +++ b/src/frontend/src/tests/instance_test.rs @@ -1123,13 +1123,11 @@ async fn test_execute_copy_to_s3(instance: Arc) { assert!(matches!(output, Output::AffectedRows(2))); let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap(); let key = env::var("GT_S3_ACCESS_KEY").unwrap(); - let url = - env::var("GT_S3_ENDPOINT_URL").unwrap_or("https://s3.amazonaws.com".to_string()); let root = uuid::Uuid::new_v4().to_string(); // exports - let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", bucket, root, key_id, key, url); + let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')", bucket, root, key_id, key); let output = execute_sql(&instance, ©_to_stmt).await; assert!(matches!(output, Output::AffectedRows(2))); @@ -1165,11 +1163,8 @@ async fn test_execute_copy_from_s3(instance: Arc) { let root = uuid::Uuid::new_v4().to_string(); let key_id = env::var("GT_S3_ACCESS_KEY_ID").unwrap(); let key = env::var("GT_S3_ACCESS_KEY").unwrap(); - let url = - env::var("GT_S3_ENDPOINT_URL").unwrap_or("https://s3.amazonaws.com".to_string()); - let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", bucket, root, key_id, key, url); - logging::info!("Copy table to s3: {}", copy_to_stmt); + let copy_to_stmt = format!("Copy demo TO 's3://{}/{}/export/demo.parquet' CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')", bucket, root, key_id, key); let output = execute_sql(&instance, ©_to_stmt).await; assert!(matches!(output, Output::AffectedRows(2))); @@ -1210,8 +1205,8 @@ async fn test_execute_copy_from_s3(instance: Arc) { ) .await; let sql = format!( - "{} CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}',ENDPOINT_URL='{}')", - test.sql, key_id, key, url + "{} CONNECTION (ACCESS_KEY_ID='{}',SECRET_ACCESS_KEY='{}')", + test.sql, key_id, key ); logging::info!("Running sql: {}", sql);