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 index 7a46aefe6a37..8a5454368bfb 100644 --- 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 index 420b31046187..edfd2324d900 100644 --- 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(