YQ-2899 fix url escaping (ydb-platform#3439)

EgorkaZ · Apr 8, 2024 · dec9e00 · dec9e00
1 parent add75cc
commit dec9e00
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp b/ydb/library/yql/providers/s3/actors/yql_s3_read_actor.cpp
@@ -1829,7 +1829,7 @@ class TS3ReadCoroImpl : public TActorCoroImpl {
         if (it != RangeCache.end()) {
             return it->second;
         }
-        RetryStuff->Gateway->Download(Url + Path, RetryStuff->Headers,
+        RetryStuff->Gateway->Download(RetryStuff->Url, RetryStuff->Headers,
                             range.Offset,
                             range.Length,
                             std::bind(&OnResult, GetActorSystem(), SelfActorId, range, ++RangeCookie, std::placeholders::_1),

diff --git a/ydb/tests/fq/s3/test_insert.py b/ydb/tests/fq/s3/test_insert.py
@@ -21,7 +21,7 @@ def create_bucket_and_upload_file(self, filename, s3, kikimr):
 
     @yq_all
     @pytest.mark.parametrize("dataset_name", ["dataset", "dataにちは% set"])
-    @pytest.mark.parametrize("format", ["json_list", "json_each_row", "csv_with_names"])
+    @pytest.mark.parametrize("format", ["json_list", "json_each_row", "csv_with_names", "parquet"])
     @pytest.mark.parametrize("client", [{"folder_id": "my_folder"}], indirect=True)
     def test_insert(self, kikimr, s3, client, format, dataset_name):
         resource = boto3.resource(